Dawid Wysakowicz created FLINK-23475:
----------------------------------------
Summary: Handle BroadcastState with finished operators
Key: FLINK-23475
URL: https://issues.apache.org/jira/browse/FLINK-23475
Project: Flink
Issue Type: Improvement
Components: Runtime / Checkpointing
Reporter: Dawid Wysakowicz
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)
