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

shengjk1 commented on FLINK-11336:
----------------------------------

hi, [~till.rohrmann] 

I have other questions and suggestions:

 1. I want to know if  will also delete invalid directories on HDFS, similar to 
zk metadata?  because most of the metadata of HA is stored on HDFS. such as 
when  job is failed.

 2. when the job is canceled, the job's metadata is  deleted as default , but i 
think it also should  delete the corresponding directory, such as 
\{{jobId}}/shared and \{{jobId}}/taskowned. 

 

 

> Flink HA didn't remove ZK metadata
> ----------------------------------
>
>                 Key: FLINK-11336
>                 URL: https://issues.apache.org/jira/browse/FLINK-11336
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Coordination
>            Reporter: shengjk1
>            Assignee: Till Rohrmann
>            Priority: Major
>         Attachments: image-2019-01-15-19-42-21-902.png
>
>
> Flink HA didn't remove ZK metadata
> such as 
> go to zk cli  : ls /flinkone
> !image-2019-01-15-19-42-21-902.png!
>  
> i suggest we should delete this metadata when the application  cancel or 
> throw exception



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to