[
https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16063003#comment-16063003
]
Till Rohrmann commented on FLINK-6522:
--------------------------------------
Hi [~zjureel], yes clean up will entail removing all Zk data written under the
root path. Additionally we have to cleanup the data written to the
{{SubmittedJobGraphStore}}. For that, we probably have to keep a reference to
the {{RetrievableStateStorageHelper}} used by the created
{{ZooKeeperSubmittedJobGraphStore}}. This might entail some refactorings for
the {{ZooKeeperUtils}} methods.
> Add ZooKeeper cleanup logic to ZooKeeperHaServices
> --------------------------------------------------
>
> Key: FLINK-6522
> URL: https://issues.apache.org/jira/browse/FLINK-6522
> Project: Flink
> Issue Type: Improvement
> Components: Distributed Coordination
> Affects Versions: 1.3.0, 1.4.0
> Reporter: Till Rohrmann
>
> The {{ZooKeeperHaServices}} provide a {{CuratorFramework}} client to access
> ZooKeeper data. Consequently, all data (also for different job) are stored
> under the same root node. When
> {{HighAvailabilityServices#closeAndCleanupAllData}} is called, then this data
> should be cleaned up. This cleanup logic is currently missing.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
