我有两份工作,jobA 和 jobB。当我取消jobA时,jobB同时失败。 jobB 抛出
org.apache.flink.util.FlinkException: Releasing shared slot parent
这是什么意思以及如何解决它?
Flink 版本 1.6.0
我有 setting a slot sharing group 的隔离槽对于我的工作:
someStream.filter(...).slotSharingGroup("name");
但是它不起作用。
最佳答案
升级到flink 1.9后该问题得到解决
关于java - org.apache.flink.util.FlinkException : Releasing shared slot parent,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54924020/