(paimon) branch master updated: [cdc] Set eager_init with option during kafka_sync_database (#5175)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 1d128b74ef [cdc] Set eager_init with option during kafka_sync_database 
(#5175)
1d128b74ef is described below

commit 1d128b74ef5b585950bb6f0ce566474a7baf90cf
Author: JackeyLee007 <jackeylee...@126.com>
AuthorDate: Thu Feb 27 21:41:59 2025 +0800

    [cdc] Set eager_init with option during kafka_sync_database (#5175)
---
 .../java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtils.java | 1 +
 .../apache/paimon/flink/action/cdc/SyncDatabaseActionFactoryBase.java | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtils.java
 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtils.java
index c107500eba..be63b5a43f 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtils.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/CdcActionCommonUtils.java
@@ -69,6 +69,7 @@ public class CdcActionCommonUtils {
     public static final String COMPUTED_COLUMN = "computed_column";
     public static final String METADATA_COLUMN = "metadata_column";
     public static final String MULTIPLE_TABLE_PARTITION_KEYS = 
"multiple_table_partition_keys";
+    public static final String EAGER_INIT = "eager_init";
 
     public static void assertSchemaCompatible(
             TableSchema paimonSchema, List<DataField> sourceTableFields) {
diff --git 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncDatabaseActionFactoryBase.java
 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncDatabaseActionFactoryBase.java
index 4c7bd9cc1b..52bfb7271c 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncDatabaseActionFactoryBase.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/SyncDatabaseActionFactoryBase.java
@@ -24,6 +24,7 @@ import 
org.apache.paimon.flink.action.MultipleParameterToolAdapter;
 
 import java.util.Optional;
 
+import static 
org.apache.paimon.flink.action.cdc.CdcActionCommonUtils.EAGER_INIT;
 import static 
org.apache.paimon.flink.action.cdc.CdcActionCommonUtils.EXCLUDING_DBS;
 import static 
org.apache.paimon.flink.action.cdc.CdcActionCommonUtils.EXCLUDING_TABLES;
 import static 
org.apache.paimon.flink.action.cdc.CdcActionCommonUtils.INCLUDING_DBS;
@@ -63,7 +64,8 @@ public abstract class SyncDatabaseActionFactoryBase<T extends 
SyncDatabaseAction
                 .excludingDbs(params.get(EXCLUDING_DBS))
                 .withPartitionKeyMultiple(
                         optionalConfigMapList(params, 
MULTIPLE_TABLE_PARTITION_KEYS))
-                .withPartitionKeys();
+                .withPartitionKeys()
+                .eagerInit(Boolean.valueOf(params.get(EAGER_INIT)));
 
         if (params.has(PARTITION_KEYS)) {
             action.withPartitionKeys(params.get(PARTITION_KEYS).split(","));