Dawid Wysakowicz created FLINK-22815:
----------------------------------------
Summary: Disable unaligned checkpoints for broadcast partitioning
Key: FLINK-22815
URL: https://issues.apache.org/jira/browse/FLINK-22815
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Affects Versions: 1.12.4, 1.13.1
Reporter: Dawid Wysakowicz
Assignee: Dawid Wysakowicz
Fix For: 1.14.0, 1.12.5, 1.13.2
Broadcast partitioning can not work with unaligned checkpointing. There
are no guarantees that records are consumed at the same rate in all
channels. This can result in some tasks applying state changes
corresponding to a certain broadcasted event while others don't. In turn
upon restore, it may lead to an inconsistent state.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
