[ 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)