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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
