[jira] [Created] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22815) Disable unaligned checkpoints for broadcast partitioning

Shang Yuanchun (Jira)
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)