This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 81a5682208 [core] Fix remaining byte[] identity comparisons in collect
and merge_map aggregators (#9870)
add ce6884bcd1 [cdc] Support per-table configuration for MySQL database
CDC (#9871)
No new revisions were added by this update.
Summary of changes:
docs/docs/cdc-ingestion/action-configuration.mdx | 14 +++--
docs/docs/cdc-ingestion/mysql-cdc.mdx | 21 ++++++++
.../flink/action/cdc/CdcActionCommonUtils.java | 38 +++++++++++++
.../flink/action/cdc/SyncDatabaseActionBase.java | 1 +
.../action/cdc/SynchronizationActionBase.java | 23 +++++++-
.../cdc/SynchronizationActionFactoryBase.java | 8 +++
.../action/cdc/mysql/MySqlSyncDatabaseAction.java | 8 ++-
.../cdc/mysql/MySqlSyncDatabaseActionFactory.java | 3 +-
.../flink/sink/cdc/NewTableSchemaBuilder.java | 14 ++++-
.../flink/action/cdc/CdcActionCommonUtilsTest.java | 62 ++++++++++++++++++++++
.../flink/action/cdc/CdcActionITCaseBase.java | 7 +++
.../cdc/mysql/MySqlSyncDatabaseActionITCase.java | 39 ++++++++++++++
12 files changed, 230 insertions(+), 8 deletions(-)
create mode 100644
paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtilsTest.java
