[
https://issues.apache.org/jira/browse/FLINK-24065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413871#comment-17413871
]
Yun Gao commented on FLINK-24065:
---------------------------------
Fix on master via fdf40d2e0efe2eed77ca9633121691c8d1e744cb
Fix on release-1.14 via 22e76173c43000ddc4ff5ec6372df8ef1acf2057
> 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)
