我有两个工作,jobA和jobB。取消jobA时,jobB同时失败。然后jobB抛出


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


这是什么意思,以及如何解决?

Flink版本1.6.0

我已经通过setting a slot sharing group隔离了我的工作:

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


但它不起作用。

最佳答案

升级到flink 1.9后,此问题得到解决

10-08 04:00