[
https://issues.apache.org/jira/browse/FLINK-23475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17397749#comment-17397749
]
Yuan Mei commented on FLINK-23475:
----------------------------------
merged commit
[{{1c563a0}}|https://github.com/apache/flink/commit/1c563a03e95a7baf91055ce1fec3d2a6f35c393d]
into apache:master
> Handle BroadcastState with finished operators
> ---------------------------------------------
>
> Key: FLINK-23475
> URL: https://issues.apache.org/jira/browse/FLINK-23475
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing
> Reporter: Dawid Wysakowicz
> Assignee: Yun Gao
> Priority: Major
> Labels: pull-request-available
>
> BroadcastState assumes all subtasks state is the same. When rescaling it
> reassigns states of all tasks to new tasks. If the parallelism is different
> it assigns the old states to new range of states in a round robin fashion.
> We must make sure that an empty state is not reassigned to running subtasks
> in
> {{org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner#repartitionBroadcastState}}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
