This is an automated email from the ASF dual-hosted git repository.
yuzelin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
from a6b18d80b [core] AddPartitionCommitCallback should only be created for
partitioned table (#1828)
add 238e826e4 [flink] Refactor update data fields process function (#1822)
No new revisions were added by this update.
Summary of changes:
...MultiTableUpdatedDataFieldsProcessFunction.java | 156 +---------------
.../sink/cdc/UpdatedDataFieldsProcessFunction.java | 203 +--------------------
...a => UpdatedDataFieldsProcessFunctionBase.java} | 157 +++++++---------
3 files changed, 71 insertions(+), 445 deletions(-)
copy
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/cdc/{UpdatedDataFieldsProcessFunction.java
=> UpdatedDataFieldsProcessFunctionBase.java} (87%)
