[improve]change use-new-schema-change config deafult to true (apache#318

)
JNSimba · Feb 23, 2024 · 2e123bf · 2e123bf
1 parent d41e035
commit 2e123bf
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java
@@ -89,7 +89,9 @@ public String getAvailableBackend() {
 
     public static boolean tryHttpConnection(String host) {
         try {
-            LOG.info("try to connect host {}", host);
+            if (LOG.isDebugEnabled()) {
+                LOG.debug("try to connect host {}", host);
+            }
             host = "http://" + host;
             URL url = new URL(host);
             HttpURLConnection co = (HttpURLConnection) url.openConnection();

diff --git a/...main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java b/...main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java
@@ -196,7 +196,7 @@ public static class Builder {
         private DorisOptions dorisOptions;
         private Pattern addDropDDLPattern;
         private String sourceTableName;
-        private boolean newSchemaChange;
+        private boolean newSchemaChange = true;
         private DorisExecutionOptions executionOptions;
         private Map<String, String> tableMapping;
         private Map<String, String> tableProperties;

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();

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java
@@ -73,7 +73,7 @@ public abstract class DatabaseSync {
 
     public StreamExecutionEnvironment env;
     private boolean createTableOnly = false;
-    private boolean newSchemaChange;
+    private boolean newSchemaChange = true;
     protected String includingTables;
     protected String excludingTables;
     protected String multiToOneOrigin;