[
https://issues.apache.org/jira/browse/FLINK-24065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-24065:
--------------------------------------
Assignee: Yun Gao
> 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: Major
>
> 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)
