This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
from 5651716c7 [doc] Fix compile error in cdc ingestion
add 934322806 [flink][cdc] Build all the cdc test actions from arguments
(#1909)
No new revisions were added by this update.
Summary of changes:
.../org/apache/paimon/flink/action/ActionBase.java | 2 +
.../paimon/flink/action/cdc/DatabaseSyncMode.java | 4 +
.../paimon/flink/action/cdc/TypeMapping.java | 6 +-
.../action/cdc/kafka/KafkaSyncDatabaseAction.java | 20 +-
.../action/cdc/kafka/KafkaSyncTableAction.java | 43 ++-
.../cdc/kafka/KafkaSyncTableActionFactory.java | 2 +-
.../cdc/mongodb/MongoDBSyncDatabaseAction.java | 29 +-
.../action/cdc/mongodb/MongoDBSyncTableAction.java | 22 +-
.../action/cdc/mysql/MySqlSyncDatabaseAction.java | 15 +-
.../action/cdc/mysql/MySqlSyncTableAction.java | 17 +-
.../paimon/flink/action/ActionITCaseBase.java | 47 ++--
.../flink/action/CompactDatabaseActionITCase.java | 2 -
.../flink/action/cdc/CdcActionITCaseBase.java | 309 +++++++++++++++++++++
.../action/cdc/kafka/KafkaActionITCaseBase.java | 210 ++++++++------
.../kafka/KafkaCanalSyncDatabaseActionITCase.java | 187 +++++--------
.../cdc/kafka/KafkaCanalSyncTableActionITCase.java | 289 +++++++------------
.../kafka/KafkaOggSyncDatabaseActionITCase.java | 194 +++++--------
.../cdc/kafka/KafkaOggSyncTableActionITCase.java | 212 +++++---------
.../cdc/mongodb/MongoDBActionITCaseBase.java | 195 +++++++------
.../mongodb/MongoDBSyncDatabaseActionITCase.java | 32 ++-
.../cdc/mongodb/MongoDBSyncTableActionITCase.java | 58 ++--
.../action/cdc/mysql/MySqlActionITCaseBase.java | 171 +++++-------
.../cdc/mysql/MySqlCdcTypeMappingITCase.java | 40 +--
.../cdc/mysql/MySqlSyncDatabaseActionITCase.java | 168 ++++++-----
.../mysql/MySqlSyncDatabaseTableListITCase.java | 32 +--
.../cdc/mysql/MySqlSyncTableActionITCase.java | 94 ++++---
26 files changed, 1245 insertions(+), 1155 deletions(-)
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/cdc/CdcActionITCaseBase.java
