我的flink应用在ieda可以运行成功，提交集群后运行报错，提示：Cannot have more than one execute() or executeAsyc() call in a single environment，我查看源码，是根据job manager是否高可用做的判断，我不太理解这个和高可用有什么关系？烦请解答一下！谢谢！ 错误位置org.apache.flink.client.program.StreamContextEnvironment.validateAllowedExecution()方法，139行；*来自志愿者整理的flink邮件归档
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
你的这个报错应该是使用1.11里面新增的application mode来运行的吧
因为目前application mode不能支持在HA模式下，一个Flink cluster里运行多个任务，所以会报上面的错 原因是用户可能在main方法里面增加了if...else等来实现Job之间的依赖关系，这种情况在HA模式下恢复可能会有问题 所以暂时不支持了。非HA的时候所有任务都会重跑，那就没有这个限制了*来自志愿者整理的flink
评论
全部评论 (0)