Can Flink可以通過java代碼將多個作業附加到Web Ui的本地環境中？

Can Flink可以通過java代碼將多個作業附加到Web Ui的本地環境中？Can Flink可以通過java代碼將多個作業附加到Web Ui的本地環境中？

我的代碼是這樣的

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

我想要做的是遍歷這個並附作業2作業3與Web UI同治相同的環境。這怎麼能在java代碼中完成？

我試圖使用env2 = StreamExecutionEnvironment.getExecutionEnvironment(), 但它似乎是新的job2不是我先前創建的envatch。

請幫我在此先感謝

來源

2017-05-09 zt1983811

您應該能夠重新使用已創建StreamExecutionEnvironment您已存儲在env。

StreamExecutionEnvironment.createLocalEnvironmentWithWebUI將不會設置相應的上下文環境工廠。因此，StreamExecutionEnvironment.getExecutionEnvironment將不會返回已啓用Web UI的已創建本地環境。

來源

2017-05-11 12:55:28

是的，我確實試圖重新啓動它，但我得到錯誤，說地址綁定已被使用，我想env嘗試使用相同的jobmanager地址出於某種原因。我會很快更新我的問題，並附上代碼和錯誤消息。感謝幫助。 – zt1983811

你說得對。問題在於底層的'LocalStreamEnvironment'爲每個'execute'使用相同的端口創建一個新的'LocalFlinkMiniCluster'。這可能會導致問題。您是否嘗試在同一本地羣集上同時運行Flink作業？ –

是的我試圖在一個本地本地羣集中運行多個作業。 – zt1983811

Can Flink可以通過java代碼將多個作業附加到Web Ui的本地環境中？

回答

相關問題