[
https://issues.apache.org/jira/browse/FLINK-26629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-26629.
------------------------------------
Fix Version/s: 1.15.0
1.14.5
Assignee: Shubin Ruan
Resolution: Fixed
Fixed in:
* master
** 65bafa043bbf79e8cc0ff3f015e5fa34681b39dc
* 1.15.0
** c4ed56a870f3fc58ac0d2af66dcd35eb5bf5b7d3
* 1.14.5
** 0d8178d11a934217747f47b342999aeba73a26e4
> 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
> Assignee: Shubin Ruan
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0, 1.14.5
>
>
> 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)
