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/paimon.git
from 8cc2309ef6 [core] NestedupdateAgg key fieldName maybe shuld be trimed
(#5142)
add 8abbc5e6f6 [cdc] Ignore decimal length and precision change by
type-mapping (#5124)
No new revisions were added by this update.
Summary of changes:
.../shortcodes/generated/kafka_sync_database.html | 1 +
.../shortcodes/generated/kafka_sync_table.html | 1 +
.../flink/action/cdc/SyncDatabaseActionBase.java | 1 +
.../flink/action/cdc/SyncTableActionBase.java | 1 +
.../paimon/flink/action/cdc/TypeMapping.java | 1 +
.../paimon/flink/sink/cdc/CdcSinkBuilder.java | 10 +++++-
.../sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java | 13 ++++++--
...MultiTableUpdatedDataFieldsProcessFunction.java | 6 ++--
.../sink/cdc/UpdatedDataFieldsProcessFunction.java | 8 +++--
.../cdc/UpdatedDataFieldsProcessFunctionBase.java | 14 ++++++++-
.../flink/action/cdc/SchemaEvolutionTest.java | 3 +-
.../cdc/kafka/KafkaCanalSyncTableActionITCase.java | 36 ++++++++++++++++++++++
.../sink/cdc/FlinkCdcSyncDatabaseSinkITCase.java | 2 ++
.../canal-data-3.txt} | 2 +-
.../canal-data-4.txt} | 2 +-
15 files changed, 90 insertions(+), 11 deletions(-)
copy
paimon-flink/paimon-flink-cdc/src/test/resources/kafka/canal/table/{incomplete/canal-data-2.txt
=> typenochange/canal-data-3.txt} (86%)
copy
paimon-flink/paimon-flink-cdc/src/test/resources/kafka/canal/table/{incomplete/canal-data-2.txt
=> typenochange/canal-data-4.txt} (80%)
