官术网_书友最值得收藏!

2.2.5 項目打包并提交Flink集群執行

如果項目想要部署到生產環境并運行,就要先打包成JAR包再進行部署。使用Maven的mvn clean package命令可以很方便地進行打包。具體操作步驟如下:

(1)打開項目中的pom.xml文件,找到以下內容并將mainClass(可同時按下快捷鍵Ctrl+F,查找mainClass)修改為當前類的全限定名稱:

(2)在IntelliJ IDEA界面最下方左側,單擊Terminal選項卡,打開Terminal窗口。在Terminal窗口中執行命令mvn clean package打包項目,如圖2-21所示。

圖2-21 執行命令mvn clean package打包項目

(3)在編譯打包過程中會輸出一系列信息,如圖2-22所示。

(4)在項目下會生成一個target目錄,打好的JAR包就在這里,如圖2-23所示。

圖2-22 打包成功提示信息

圖2-23 打包好的JAR包文件

(5)啟動Flink集群。在Linux終端中,執行的命令如下:

執行過程如圖2-24所示。

圖2-24 Flink集群啟動過程

(6)將該JAR包復制到Linux的指定目錄下,例如,~/flinkdemos/目錄下,然后提交到Flink集群上運行Job作業,命令如下:

執行結果如下:

主站蜘蛛池模板: 墨竹工卡县| 博湖县| 普安县| 郯城县| 蒲江县| 巫山县| 石嘴山市| 改则县| 西昌市| 永顺县| 蓬安县| 广州市| 微山县| 北宁市| 东乌| 吴堡县| 巴南区| 闸北区| 雷山县| 涞源县| 大港区| 武胜县| 泽普县| 天门市| 原平市| 大竹县| 贡山| 宁阳县| 安乡县| 九江市| 昆明市| 确山县| 潜山县| 玉树县| 望奎县| 高唐县| 西畴县| 晋中市| 湘潭市| 梁河县| 西乌珠穆沁旗|