[Improve](sink) deafult open auto redirect (apache#304)

Automatic redirection is turned on by default when streamload is writing.
JNSimba · Jan 23, 2024 · 11e7369 · 11e7369
1 parent c77f9d7
commit 11e7369
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java
@@ -81,7 +81,7 @@ public static class Builder {
         private String jdbcUrl;
         private String username;
         private String password;
-        private boolean autoRedirect;
+        private boolean autoRedirect = true;
         private String tableIdentifier;
 
         /** required, tableIdentifier. */

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java
@@ -72,7 +72,7 @@ public class DorisConfigOptions {
     public static final ConfigOption<Boolean> AUTO_REDIRECT =
             ConfigOptions.key("auto-redirect")
                     .booleanType()
-                    .defaultValue(false)
+                    .defaultValue(true)
                     .withDescription(
                             "Use automatic redirection of fe without explicitly obtaining the be list");