flink1.9,后台提交job失败怎么解决？
代码里面是有env.execute，提交job出现以下错误，可能时什么原因？ The program didn't contain a Flink job. Perhaps you forgot to call execute() on the execution environment.*来自志愿者整理的FLINK邮件归档
展开
收起
1
条回答
写回答
写回答
-
从你给的日志看，错误原因是“No lease on /flink/checkpoints/OnlineOrderAddressMatch/8183afb213bfbd32b49e3a6bab977f7c/chk-25/d993f40c-a8a1-4582-ad7b-ac47a2b163a0 (inode 25791993): File does not exist. Holder DFSClient_NONMAPREDUCE_1212990289_95 does not have any open files.” 也就是文件不存在了，你需要看看为什么文件不存在了，或许你可以从 audit log 中找到一些信息*来自志愿者整理的FLINK邮件归档
2021-12-03 18:55:18赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
