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

Posted to issues@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2021/09/13 02:43:00 UTC

[jira] [Closed] (FLINK-24065) Upgrade the TwoPhaseCommitSink to support empty transaction after finished

     [ https://issues.apache.org/jira/browse/FLINK-24065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Yun Gao closed FLINK-24065.
---------------------------
    Resolution: Fixed

> Upgrade the TwoPhaseCommitSink to support empty transaction after finished
> --------------------------------------------------------------------------
>
>                 Key: FLINK-24065
>                 URL: https://issues.apache.org/jira/browse/FLINK-24065
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Common, Runtime / Checkpointing
>    Affects Versions: 1.14.0
>            Reporter: Yun Gao
>            Assignee: Yun Gao
>            Priority: Critical
>              Labels: pull-request-available
>             Fix For: 1.14.0
>
>
> In https://issues.apache.org/jira/browse/FLINK-23473 for the TwoPhaseCommitSink, we would not create new transactions after finished to avoid we have transactions left after job finished. However, since with the current implementation of the TwoPhaseCommitSink, we would have to write the transactions into the state for each checkpoint, and the state does not support null transaction now, thus there would be NullPointerException in this case. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)