后,该问题解决了
我有两个工作,Joba和JobB。当我取消JobA时,JobB同时失败。和JobB投掷
org.apache.flink.util.flinkexception:释放共享插槽parent
它是什么意思,如何修复它?
Flink版本1.6.0
我通过为我的工作设置一个插槽共享组来孤立:
someStream.filter(...).slotSharingGroup("name");
但行不通。
升级到Flink 1.9