AI 助理
备案控制台
开发者社区 问答 正文

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.

展开
收起
提个问题 2024-06-11 19:12:05 109 分享
分享
 版权
举报

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

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 评论

    评论

    全部评论 (0)

    登录后可评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版job 实时计算 Flink版报错 实时计算 Flink版报错job 实时计算 Flink版detached 实时计算 Flink版报错mode
问答地址：
开发者社区 > 大数据 > 问答
关联地址：
问产品> 实时计算 Flink版
相关问答
实时计算 Flink版
有人用flink写clickhouse，遇到the table is readonly mode的？
240
1
0
Flink连接holo报错Hologres rpc/bhclient mode dimensi...
78
1
0
Flink报错Hologres rpc/bhclient mode dimension tab...
58
1
0
Flink CDC里flink Application Mode模式有必要部署 HA吗？
75
2
0
Flink报错OVER windows' ordering in stream mode mu...
335
1
0
Flink CDC里flink Application Mode模式集群部署模式主要包含什么？
70
0
0
flink Application Mode模式 有必要 部署 HA吗?
55
0
0
Flink如果用 app mode 就无需关心这个问题了，对吗？
40
1
0
咱们这个flink是类似on K8s native session mode的模式吗？
60
1
0
flink on yarn application mode 有人遇到过吗，flink只能提交一个任
460
3
0