(doris-flink-connector) branch master updated: [Improve](sink) deafult open auto redirect (#304)

[zykkk]

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

zykkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 11e7369  [Improve](sink) deafult open auto redirect (#304)
11e7369 is described below

commit 11e7369f3308323f619787cd66ef1f80fd353165
Author: wudi <676366...@qq.com>
AuthorDate: Tue Jan 23 15:45:51 2024 +0800

    [Improve](sink) deafult open auto redirect (#304)
    
    Automatic redirection is turned on by default when streamload is writing.
---
 .../src/main/java/org/apache/doris/flink/cfg/DorisOptions.java          | 2 +-
 .../src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java  | 2 +-
 2 files changed, 2 insertions(+), 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
index 9a4506a..f1dd2a5 100644
--- 
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 class DorisOptions extends DorisConnectionOptions {
         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
index e7b5ce7..e368e31 100644
--- 
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");
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org