[
https://issues.apache.org/jira/browse/FLINK-23475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-23475:
----------------------------------------
Assignee: Yun Gao
> 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)
