Search code examples
javaapache-flink

org.apache.flink.util.FlinkException: Releasing shared slot parent


I have two jobs, jobA and jobB. When I cancel jobA, jobB fails at the same time. And jobB throws

org.apache.flink.util.FlinkException: Releasing shared slot parent

What does it mean and how to fix it?

Flink Version 1.6.0

I have isolated slots by setting a slot sharing group for my job:

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

but it does not work.


Solution

  • This problem gets solved after upgrading to flink 1.9