You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Fabian Paul (Jira)" <ji...@apache.org> on 2022/02/02 09:13:00 UTC

[jira] [Created] (FLINK-25920) Allow receiving updates of CommittableSummary

Fabian Paul created FLINK-25920:
-----------------------------------

             Summary: Allow receiving updates of CommittableSummary
                 Key: FLINK-25920
                 URL: https://issues.apache.org/jira/browse/FLINK-25920
             Project: Flink
          Issue Type: Sub-task
          Components: API / DataStream, Connectors / Common
    Affects Versions: 1.15.0, 1.16.0
            Reporter: Fabian Paul


In the case of unaligned checkpoints, it might happen that the checkpoint barrier overtakes the records and an empty committable summary is emitted that needs to be correct at a later point when the records arrive.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)