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