Till Rohrmann created FLINK-5942:
------------------------------------
Summary: Harden ZooKeeperStateHandleStore to deal with corrupted data
Key: FLINK-5942
URL:
https://issues.apache.org/jira/browse/FLINK-5942 Project: Flink
Issue Type: Bug
Components: State Backends, Checkpointing
Affects Versions: 1.1.4, 1.2.0, 1.3.0
Reporter: Till Rohrmann
Assignee: Till Rohrmann
The {{ZooKeeperStateHandleStore}} cannot handle corrupted Znode data. When calling {{ZooKeeperStateHandleStore.getAll}} or {{getAllSortedByName}} and reading a node with corrupted data, the whole operation will fail. In such a situation, Flink won't be able to recover because it will read over and over again the same corrupted Znodes (in the recovery case). Therefore, I propose to ignore Znodes whose data cannot be read.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)