2022-01-20 09:25:58,308 WARN org.apache.flink.client.deployment.application.DetachedApplicationRunner [] - Could not execute application:
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Job was submitted in detached mode. Results of job execution, such as accumulators, runtime, etc. are not available. Please make sure your program doesn't call an eager execution function [collect, print, printToErr, count]

这是因为当 flink 作业是以 detached 模式提交的时候,作业不能以 collect, print, printToErr, count 等 operator 做结尾,当作业以 blocking 模式提交的时候就没有这些限制。

detached : 指的是通过客户端、Java API 或 Restful 等方式提交的,就是相当于咱们提交上去以后,是不能看到作业的运行结果的,必须去看日志才能知道作业的运行情况,有点异步回调的感觉

blocking:指的是在 IDEA 或者其他方式直接启动的,咱们可以通过关闭终端或 Ctrl + C 的方式直接关闭 正在运行的 flink 作业(https://blog.csdn.net/wuleidaren/article/details/110648032)