Flink提交任務(第一篇)——打包任務程序

文章目錄 1. 引言 2. buildProgram的執行邏輯 2.1. 若是沒有指定入口類名稱,那麼就從jar包裏找出來 2.2. 提取任務jar文件中全部依賴的JAR包 2.3. 經過入口類名稱來真正加載執行入口類 針對flink-1.7-release 1. 引言 Flink客戶端經過命令行的形式提交任務時,即執行./flink run xxxx.jar時,真正執行的run邏輯以下:java
相關文章
相關標籤/搜索