运行办法:
①mvn clean
②mvn package
③运行
④新开一个终端
扫描二维码关注公众号,回复:
11845431 查看本文章
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