zlzhang0122 created FLINK-24207: ----------------------------------- Summary: Add support of KeyedState in TwoPhaseCommitSinkFunction Key: FLINK-24207 URL: https://issues.apache.org/jira/browse/FLINK-24207 Project: Flink Issue Type: New Feature Components: Runtime / Checkpointing Affects Versions: 1.13.1, 1.12.2 Reporter: zlzhang0122 Fix For: 1.14.1
Now, the implementation of TwoPhaseCommitSinkFunction is based on operator state, but operator state will do a deep copy when taking checkpoint, so large operator state may produce a OOM error. Add support of KeyedState in TwoPhaseCommitSinkFunction maybe a good choice to avoid the OOM error and give users more convenience. -- This message was sent by Atlassian Jira (v8.3.4#803005)