flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "shengjk1 (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-11336) Flink HA didn't remove ZK metadata
Date Fri, 01 Mar 2019 12:28:00 GMT

    [ 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)

Mime
View raw message