Flink报错Job was submitted in detached mode. Resu...
已解决Flink报错Job was submitted in detached mode. Results of job execution, such as accumulators, runtime, etc. are not available.
展开
收起
1
条回答
写回答
写回答
-
开发者社区问答官方账号官方回答采纳回答【报错详情】Caused by: org.apache.flink.api.common.InvalidProgramException: 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和Blocking两种提交模式：- Detached是指通过客户端、Java API或RESTful等方式提交的，提交后无法看到作业的运行结果，需通过日志查看作业运行情况，类似于异步回调。
- Blocking是指在IDEA或者其他方式直接启动的，可以通过关闭终端或Ctrl+C的方式直接关闭正在运行的Flink作业。
当Flink作业以Detached模式提交时，不能以Collect、Print、PrintToErr或Count等Operator做结尾。当作业以Blocking模式提交时，没有这些限制。【解决方案】- 使用SQL作业运行。
- TableAPI JAR作业不要以Collect、Print、PrintToErr或Count等Operator做结尾。
2024-06-11 19:12:06赞同 1 展开评论 打赏
问答分类：
关联地址：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
