[hotfix][state] Fix incorrect comments of channel input state redistr…

…ibution.
jonchase · Jun 16, 2023 · 65c3ce4 · 65c3ce4
1 parent 52dfc29
commit 65c3ce4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...k-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java b/...k-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java
@@ -432,7 +432,7 @@ public void reDistributeInputChannelStates(TaskStateAssignment stateAssignment)
         // old assignment: 0 -> [0;43); 1 -> [43;87); 2 -> [87;128)
         // new assignment: 0 -> [0;64]; 1 -> [64;128)
         // subtask 0 recovers data from old subtask 0 + 1 and subtask 1 recovers data from old
-        // subtask 0 + 2
+        // subtask 1 + 2
         for (int gateIndex = 0; gateIndex < inputs.size(); gateIndex++) {
             final RescaleMappings mapping =
                     stateAssignment.getInputMapping(gateIndex).getRescaleMappings();