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
相关文章
相关标签/搜索