2017-07-12 58 views
0

我已經寫了flink作業來使用數據集和數據流api。我已經從相同的main()方法啓動了兩個程序但是現在當我將作業提交到flink Dashboard時。只有數據集api程序正在運行,儀表板表示作業已完成,流未觸發,flink儀表板也未顯示有關數據流執行的任何內容。但是當我從eclipse運行時,數據集和數據流api程序都在運行。有沒有其他方式將工作提交給flink job manager來完成這項工作?如何提交flink作業,而不是使用他們的儀表板?

回答

0

除了使用網絡信息中心,你也可以使用command line interfaceREST api作業提交到弗林克。

然而,這聽起來像也許你正在嘗試同時使用兩個DataSet並的數據流中的API一個弗林克工作。這不起作用。

0

的解決方案是將兩個節目劃分成單獨的類,例如MyStreamingProgramMyBatchProgram,每個都有main方法。然後,將每個程序分別提交給Flink,以創建兩個獨立的作業。

你提到在行爲中觀察到的一些變化,根據工作是如何提交。在引擎蓋下,Flink使用各種策略來執行main方法來獲得程序計劃。不支持在main的單次執行中生成多個計劃(AFAIK)。

相關問題