开发者社区> 问答> 正文

1.11版本,执行任务报错:Cannot have more than one execute

我的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邮件归档

展开
收起
游客sadna6pkvqnz6 2021-12-07 17:27:15 1748 0
1 条回答
写回答
取消 提交回答
  • 你的这个报错应该是使用1.11里面新增的application mode来运行的吧

    因为目前application mode不能支持在HA模式下,一个Flink cluster里运行多个任务,所以会报上面的错 原因是用户可能在main方法里面增加了if...else等来实现Job之间的依赖关系,这种情况在HA模式下恢复可能会有问题 所以暂时不支持了。非HA的时候所有任务都会重跑,那就没有这个限制了*来自志愿者整理的flink

    2021-12-07 21:04:18
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Spark SQL: Past, Present and Future 立即下载
Spark SQL:Past Present &Future 立即下载
低代码开发师(初级)实战教程 立即下载