我有两个工作,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后,此问题得到解决
我有两个工作,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后,此问题得到解决