Yun Gao created FLINK-24065:
-------------------------------
Summary: 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
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)
