org.apache.flink.util.flinkexception:释放共享插槽父



我有两个工作,Joba和JobB。当我取消JobA时,JobB同时失败。和JobB投掷

org.apache.flink.util.flinkexception:释放共享插槽parent

它是什么意思,如何修复它?

Flink版本1.6.0

我通过为我的工作设置一个插槽共享组来孤立:

someStream.filter(...).slotSharingGroup("name");

但行不通。

升级到Flink 1.9

后,该问题解决了

相关内容

  • 没有找到相关文章

最新更新