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)