update

apache · Feb 22, 2024 · 42cdf52 · 42cdf52
1 parent 5e62910
commit 42cdf52
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java
@@ -117,7 +117,6 @@ private static void syncDatabase(
         String multiToOneTarget = params.get("multi-to-one-target");
         boolean createTableOnly = params.has("create-table-only");
         boolean ignoreDefaultValue = params.has("ignore-default-value");
-        boolean useNewSchemaChange = params.has("use-new-schema-change");
         boolean singleSink = params.has("single-sink");
 
         Preconditions.checkArgument(params.has("sink-conf"));
@@ -140,7 +139,6 @@ private static void syncDatabase(
                 .setSinkConfig(sinkConfig)
                 .setTableConfig(tableMap)
                 .setCreateTableOnly(createTableOnly)
-                .setNewSchemaChange(useNewSchemaChange)
                 .setSingleSink(singleSink)
                 .create();
         databaseSync.build();