[hotfix][checkpointing] Properly record amount of processed data

xinggit · Apr 22, 2021 · 79dad1a · 79dad1a
1 parent 6fb073e
commit 79dad1a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpointStats.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpointStats.java
@@ -136,7 +136,7 @@ public class PendingCheckpointStats extends AbstractCheckpointStats {
         super(checkpointId, triggerTimestamp, props, totalSubtaskCount, taskStats);
         this.trackerCallback = checkNotNull(trackerCallback);
         this.currentStateSize = currentStateSize;
-        this.currentPersistedData = processedData;
+        this.currentProcessedData = processedData;
         this.currentPersistedData = persistedData;
         this.latestAcknowledgedSubtask = latestAcknowledgedSubtask;
         this.currentNumAcknowledgedSubtasks = acknowledgedSubtaskCount;