[jira] [Created] (FLINK-10129) Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster

["Keshav Lodhi (JIRA)" <ji...@apache.org>]

Keshav Lodhi created FLINK-10129:
------------------------------------

             Summary: Flink job IDs are not getting deleted automatically from zookeeper metadata after canceling flink job in flink HA cluster 
                 Key: FLINK-10129
                 URL: https://issues.apache.org/jira/browse/FLINK-10129
             Project: Flink
          Issue Type: Bug
            Reporter: Keshav Lodhi


Hi Team,

Here is, what i am looking for:
 * We have  flink HA dockerized cluster with (3 zookeepers, 2 job-managers, 3 task-managers) 
 * So whenever we are cancelling the flink job, it is getting cancelled but it is not deleting the cancelled job ID from the zookeeper metadata (Inside flink/jobgraph folder in zookeeper) automatically. 
 * So whenever any one of the job-manager goes down/restarted , it doesn't come up and throws exception like  "Could not find this job id xxxxxxxxxx".
 * The current work around is to remove the canceled job ID from the zookeeper metadata manually. (But this is not the recommended solution).     

 

Please advise.



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