[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
apache · Dec 26, 2021 · 6cf330973a715aadf353cf27f19635e0546cbc78 · 6cf3309
1 parent 6c0627a
commit 6cf330973a715aadf353cf27f19635e0546cbc78
Showing 1 changed file with 2 additions and 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
@@ -28,8 +28,8 @@
 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;