[flink] branch master updated: [hotfix][state] Fix incorrect comments of channel input state redistribution.

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guoweijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 65c3ce43bfe [hotfix][state] Fix incorrect comments of channel input state redistribution.
65c3ce43bfe is described below

commit 65c3ce43bfe1a0df870c8e6002a7980d77291f64
Author: Weijie Guo <re...@163.com>
AuthorDate: Thu Jun 15 19:38:03 2023 +0800

    [hotfix][state] Fix incorrect comments of channel input state redistribution.
---
 .../org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java
index e476c6b65ec..63589b49ffb 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java
@@ -432,7 +432,7 @@ public class StateAssignmentOperation {
         // 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();