flink1.11 streaming和table&sql混合使用提交到yarn会启动两个applicaion

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink1.11 streaming和table&sql混合使用提交到yarn会启动两个applicaion

kingdomad
消费kafka流,用tableEnv创建视图,再用tableEnv.executeSql执行insert语句写入hive表。
如果程序中出现了StreamExecutionEnvironment.execute,提交到yarn会启动两个applicaion。
如果把StreamExecutionEnvironment.execute注释掉,则只会有一个applicaion。
求助大佬们,
这是正常的吗?
flink这是把table&sql的逻辑放在一个application上,streaming的逻辑放在另一个application上吗?













--

kingdomad