java - Flink 可以通过 java 代码将多个作业附加到 Web Ui 的 Stream 本地环境吗？

Question

Flink 可以通过 Java 代码将多个作业附加到 Web Ui 的 Stream 本地环境吗？

我的代码是这样的

env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(config); 
env.addSource(...); 
env.addSink(...); 
env.execute("stream job1"); 

我想做的是循环执行此操作，并使用 Web ui 管理将 job2 job3 连接到同一环境。在java代码中如何实现这一点呢？

我尝试使用env2 = StreamExecutionEnvironment.getExecutionEnvironment()， 但似乎新的 job2 没有附加到我之前创建的环境。

请帮助我提前致谢

Answer 1

您应该能够重复使用已创建的存储在 env 中的 StreamExecutionEnvironment。

StreamExecutionEnvironment.createLocalEnvironmentWithWebUI 不会设置相应的上下文环境工厂。因此，StreamExecutionEnvironment.getExecutionEnvironment不会返回创建的启用了 Web UI 的本地环境。