Github user kbialek commented on the pull request: https://github.com/apache/flink/commit/13bb32ef891428fe9e0e14b6ecc525f15c52c40a#commitcomment-27763936 This change broke my flink-consul implementation. That is not a big deal, however I wonder if it wouldn't break ZK recovery. As far as I understood the code in ZooKeeperCompletedCheckpointStore.recover() it compares two Lists of CompletedCheckpoints (line 201). When there is no equals() defined in CompletedCheckpoint class those comparision will never succeed.
---