Skip to content
This repository has been archived by the owner on Sep 2, 2022. It is now read-only.

Cancel jobs and take savepoints when deleting a cluster #61

Closed
functicons opened this issue Oct 17, 2019 · 1 comment
Closed

Cancel jobs and take savepoints when deleting a cluster #61

functicons opened this issue Oct 17, 2019 · 1 comment
Labels
feature #a2eeef

Comments

@functicons
Copy link
Collaborator

Currently when the user issues a request to delete the session/job cluster CR, the controller simply deletes all the resources. We need to call Flink API to cancel jobs and (optionally) take savepoints before actually deleting the resources.
@functicons functicons added the feature #a2eeef label Oct 17, 2019
@functicons functicons changed the title Cancel jobs and take savepoints (optional) when deleting the cluster Cancel jobs and take savepoints (optional) when deleting a cluster Oct 17, 2019
@functicons functicons changed the title Cancel jobs and take savepoints (optional) when deleting a cluster Cancel jobs and take savepoints when deleting a cluster Oct 18, 2019
@elanv elanv mentioned this issue Oct 24, 2019
Closed
@functicons
Copy link
Collaborator Author

This has been done as a side-effect of #82. When the desiredJob == nil while observedJob != nil, the controller will try to call Flink API to take savepoint if savepointsDir is provided then cancel the job.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
feature #a2eeef
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@functicons