Flink这个问题怎么解决?我在多线程里面单独创建StreamExecutionEnvironment 执行env.addSource数据查询,然后env.excute,
为啥执行env.addSource后不往下执行env.excute了。导致任务没有提交
也不报错,没有flink client的提交日志
Flink这个问题怎么解决?[阿里云]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
Flink这个问题怎么解决?我在多线程里面单独创建StreamExecutionEnvironment 执行env.addSource数据查询,然后env.excute,
为啥执行env.addSource后不往下执行env.excute了。导致任务没有提交
也不报错,没有flink client的提交日志