[FLINK-FLINK-36115][pipeline-connector][mysql] add scan.binlog.newly-…

…added-table.enabled option to Allow to scan newly table during binlog reading stage.
apache · Aug 21, 2024 · a0cbf7c · a0cbf7c
1 parent 7173b46
commit a0cbf7c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...l/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java b/...l/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java
@@ -131,7 +131,7 @@ public DataSource createDataSource(Context context) {
         int connectMaxRetries = config.get(CONNECT_MAX_RETRIES);
         int connectionPoolSize = config.get(CONNECTION_POOL_SIZE);
         boolean scanNewlyAddedTableEnabled = config.get(SCAN_NEWLY_ADDED_TABLE_ENABLED);
-        boolean scanIncrementalNewlyAddedTableEnabled =
+        boolean scanBinlogNewlyAddedTableEnabled =
                 config.get(SCAN_BINLOG_NEWLY_ADDED_TABLE_ENABLED);
 
         validateIntegerOption(SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE, splitSize, 1);
@@ -171,7 +171,7 @@ public DataSource createDataSource(Context context) {
                         .jdbcProperties(getJdbcProperties(configMap))
                         .scanNewlyAddedTableEnabled(scanNewlyAddedTableEnabled);
 
-        if (scanIncrementalNewlyAddedTableEnabled) {
+        if (scanBinlogNewlyAddedTableEnabled) {
             String newTables = validateTableAndReturnDebeziumStyle(tables);
             configFactory.tableList(newTables);
         } else {