Details
-
Type:
Bug
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.1.4, 1.2.0, 1.3.0
-
Component/s: State Backends, Checkpointing
-
Labels:None
Description
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.
