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)