[hotfix][flink-runtime] Fix broken CheckpointStatistics.equals

See apache#14390 for more details.
shunanli-snl · Dec 16, 2020 · 3728c15 · 3728c15
1 parent e123c32
commit 3728c15
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rc/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java b/...rc/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java
@@ -226,7 +226,7 @@ public boolean equals(Object o) {
 			stateSize == that.stateSize &&
 			duration == that.duration &&
 			alignmentBuffered == that.alignmentBuffered &&
-			processedData == processedData &&
+			processedData == that.processedData &&
 			persistedData == that.persistedData &&
 			numSubtasks == that.numSubtasks &&
 			numAckSubtasks == that.numAckSubtasks &&