?

運行辦法:

?①mvn clean

②mvn package

?

③運行

?

?

④新開一個終端

nc -lk 9999

111111

111111

111111

?

這個時候intellij中是不會有任何結果的，需要到WEB UI中去查看

?

這里的Stdout其實就是$FLINK_HOME下面的.out文件，可以查看運行結果

有沒有辦法通過修改代碼來讓這些結果在intellij中輸出呢？

根據[1]是沒有辦法的

?

代碼一定要注意開頭幾行的Environment設置．

如果改成命令提交，那么代碼中的createRemoteEnvironment必須改成getExecutionEnvironment?

否則會導致mvn編譯得到的jar無法被提交

?

Reference:

[1]how to collect the result from worker node and print it in intellij

?

?

總結

以上是生活随笔為你收集整理的intellij连接真实的flink集群的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。