[
https://issues.apache.org/jira/browse/BEAM-7192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated BEAM-7192:
-------------------------------------
Status: Open (was: Triage Needed)
> Elements buffered during checkpointing may not be partitioned correctly
> -----------------------------------------------------------------------
>
> Key: BEAM-7192
> URL: https://issues.apache.org/jira/browse/BEAM-7192
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Reporter: Maximilian Michels
> Assignee: Maximilian Michels
> Priority: Major
> Fix For: 2.13.0
>
>
> When a Flink checkpoint is taken, the current bundle is finalized. The
> finalization happens when the checkpoint barrier has already been sent
> downstream; emitting elements at this point would violate the checkpoint
> barrier alignment.
> When elements are emitted during checkpointing they are buffered until the
> checkpoint is complete. We should ensure that they are keyed correctly and
> emission of the buffered elements does not interfere with any concurrent
> state requests (in case of portability).
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
