Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
kubernetes-operator-1.2.0
Description
The AbstractFlinkService#cancelSessionJob method currently does not take into consideration the current job state.
This means that if we call this on an already failed/canceld job we will get an exception from Flink:
ava.util.concurrent.ExecutionException: org.apache.flink.runtime.messages.FlinkJobNotFoundException