You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by kingdomad <ki...@163.com> on 2020/12/23 03:46:56 UTC
flink1.11 streaming和table&sql混合使用提交到yarn会启动两个applicaion
消费kafka流，用tableEnv创建视图，再用tableEnv.executeSql执行insert语句写入hive表。
如果程序中出现了StreamExecutionEnvironment.execute，提交到yarn会启动两个applicaion。
如果把StreamExecutionEnvironment.execute注释掉，则只会有一个applicaion。
求助大佬们，
这是正常的吗？
flink这是把table&sql的逻辑放在一个application上，streaming的逻辑放在另一个application上吗？
--
kingdomad