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.
This problem gets solved after upgrading to flink 1.9