| commit | 11e7369f3308323f619787cd66ef1f80fd353165 | [log] [tgz] |
|---|---|---|
| author | wudi <676366545@qq.com> | Tue Jan 23 15:45:51 2024 +0800 |
| committer | GitHub <noreply@github.com> | Tue Jan 23 15:45:51 2024 +0800 |
| tree | 6d8b32e7a71f87b9e8c1f06034ea011d122b4ba0 | |
| parent | c77f9d7a23c55d2451cbff99f9c941491de35e78 [diff] |
[Improve](sink) deafult open auto redirect (#304) Automatic redirection is turned on by default when streamload is writing.
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 @@ 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 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");