Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.15.0
Description
JobManagerRunner instances were cancellable as long as the instance was still registered in the Dispatcher.jobManagerRunnerRegistry. With the cleanup being done concurrently (i.e. not relying on the JobManagerRunnerRegistry to be cleaned up anymore), the cancellation of a job should only be possible as long as the job is not globally finished and before cleanup is triggered.
We should verify whether a job is listed in the JobResultStore and only enable the user to cancel the job if that's not the case.
Attachments
Issue Links
- Testing discovered
-
FLINK-26114 DefaultScheduler fails fatally in case of an error when shutting down the checkpoint-related resources
- Open
- links to