ninfg4vj6xvh2
ninfg4vj6xvh2_个人页
ninfg4vj6xvh2
文章
0
问答
1
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
2021年06月
-
06.23 15:34:33
回答了问题
2021-06-23 15:34:33
如何把多个FLINK SQL放到同一个Yarn JOB里
赞0 踩0 评论1
暂无更多信息
-
回答了问题
2021-06-23
如何把多个FLINK SQL放到同一个Yarn JOB里
// 运行多条 INSERT 语句，将原表数据输出到多个结果表中 StatementSet stmtSet = tEnv.createStatementSet(); // `addInsertSql` 方法每次只接收单条 INSERT 语句 stmtSet.addInsertSql( "INSERT INTO RubberOrders SELECT product, amount FROM Orders WHERE product LIKE '%Rubber%'"); stmtSet.addInsertSql( "INSERT INTO GlassOrders SELECT product, amount FROM Orders WHERE product LIKE '%Glass%'"); // 执行刚刚添加的所有 INSERT 语句 TableResult tableResult2 = stmtSet.execute(); // 通过 TableResult 来获取作业状态 System.out.println(tableResult1.getJobClient().get().getJobStatus());赞0 踩0 评论1
滑动查看更多
暂无更多信息