[
https://issues.apache.org/jira/browse/FLINK-22815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-22815.
------------------------------------
Release Note:
Unaligned checkpoints were disabled for BROADCAST exchanges.
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.
Resolution: Fixed
> 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.13.1, 1.12.4
> Reporter: Dawid Wysakowicz
> Assignee: Dawid Wysakowicz
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.11.4, 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)
