This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository
https://gitbox.apache.org/repos/asf/incubator-doris-flink-connector.git
commit 6cf330973a715aadf353cf27f19635e0546cbc78
Author: jiafeng.zhang <zhang...@gmail.com>
AuthorDate: Sun Dec 26 11:13:47 2021 +0800
[improvement](spark-connector)(flink-connector) Modify the max num of batch
written by Spark/Flink connector each time. (#7485)
Increase the default batch size and flush interval
---
src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
b/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
index 587ab07..47bb517 100644
--- a/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
+++ b/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
@@ -28,8 +28,8 @@ import java.util.Properties;
public class DorisExecutionOptions implements Serializable {
private static final long serialVersionUID = 1L;
- public static final Integer DEFAULT_BATCH_SIZE = 1000;
- public static final Integer DEFAULT_MAX_RETRY_TIMES = 3;
+ public static final Integer DEFAULT_BATCH_SIZE = 10000;
+ public static final Integer DEFAULT_MAX_RETRY_TIMES = 1;
private static final Long DEFAULT_INTERVAL_MILLIS = 10000L;
private final Integer batchSize;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
