使用flink-sql开发, 当多个insert分别写出时, 生成了多个job, 每个job都在yarn上启动了一个应用,flink的per-job模式，一个job就会申请一次资源.
-
2 问题解决// 创建语句集
val stmtSet = tab_env.createStatementSet
// 增加insert语句
stmtSet.addInsertSql("insert_01")
stmtSet.addInsertSql("insert_02")
// 执行多个INSERT 语句
val tab_result = stmtSet.execute
// 来获取作业状态
System.out.println(tab_result.getJobClient.get.getJobStatus)
-
3 相关参考flinksql 流批一体
如何把多个Flink SQL放到同一个Yarn JOB里
-
4 搜索词汇1 如何把多个Flink SQL放到同一个Yarn JOB里
