You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Shubin Ruan (Jira)" <ji...@apache.org> on 2022/03/14 08:40:00 UTC

[jira] [Created] (FLINK-26629) Error in code comment for SubtaskStateMapper.RANGE

Shubin Ruan created FLINK-26629:
-----------------------------------

             Summary: Error in code comment for SubtaskStateMapper.RANGE
                 Key: FLINK-26629
                 URL: https://issues.apache.org/jira/browse/FLINK-26629
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Network
    Affects Versions: 1.15.0
            Reporter: Shubin Ruan


The code comments for SubtaskStateMapper.RANGE are as follows:
{code:java}
 * <p>Example:<br>
 * old assignment: 0 -> [0;43); 1 -> [43;87); 2 -> [87;128)<br>
 * new assignment: 0 -> [0;64]; 1 -> [64;128)<br>
 * subtask 0 recovers data from old subtask 0 + 1 and subtask 1 recovers data from old subtask 0
 * + 2{code}
The correct code comment should be:

 
{code:java}
 * <p>Example:<br>
 * old assignment: 0 -> [0;43); 1 -> [43;87); 2 -> [87;128)<br>
 * new assignment: 0 -> [0;64]; 1 -> [64;128)<br>
 * subtask 0 recovers data from old subtask 0 + 1 and subtask 1 recovers data from old subtask 1
 * + 2{code}
*subtask 1 should recovers data from old subtask 1 + 2,not from old subtask 0 + 2*

 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)