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