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.
    



---

Reply via email to