[ 
https://issues.apache.org/jira/browse/FLINK-26336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497266#comment-17497266
 ] 

Yang Wang commented on FLINK-26336:
-----------------------------------

I think I get your point. If we update the state in the FlinkDeployment to 
suspended, then we will not have the retained the HA ConfigMap since the cancel 
the job is called. However, if we delete the FlinkDeployment directly, then the 
HA ConfigMaps will be retained.

 

I agree that we could call the {{FlinkService#cancelJob}} in 
{{{}FlinkDeloymentController#cleanup{}}}. If it failed, we could do the manual 
clean-up.

> Deletion should remove HA related configmaps also
> -------------------------------------------------
>
>                 Key: FLINK-26336
>                 URL: https://issues.apache.org/jira/browse/FLINK-26336
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Kubernetes Operator
>            Reporter: Gyula Fora
>            Priority: Critical
>
> At the moment the deletion logic simply deletes the Flink job deployment.
> As [~wangyang0918] correctly pointed out in another ticket, deployment 
> deletion does not remove HA related configmaps (this is intentional from 
> Flink side)
> This means if the user were to resubmit a new FlinkDeployment under the same 
> name, the job would pick up the HA state and the last checkpoint from the 
> delete resource. This is probably unexpected and we should delete the 
> configmaps after deleting the deployment.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to