我试图用Flink编写一个计算,它需要两个阶段。/bin/flink run ...的命令行中),但是当我使用它的WebUI在Flink上提交作业时,程序只是执行到collect()方法,并且不运行程序的其余部分(用于语句和print())。这是我的代码:import org.apache.flink.api.java.ExecutionEnviron
我正在尝试建立一个非常基本的flink工作。at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:53) at com