java - org.apache.flink.util.FlinkException：释放共享槽父

Question

我有两个工作，jobA 和jobB。当我取消jobA时，jobB同时失败。而jobB抛出

org.apache.flink.util.FlinkException：释放共享槽父

这是什么意思以及如何解决它？

Flink 版本 1.6.0

我通过为我的工作设置一个插槽共享组来隔离插槽：

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

但它不起作用。

标签： javaapache-flink

Answer 1

升级到 flink 1.9 后这个问题得到解决