update

JNSimba · Sep 3, 2024 · 0a4a96e · 0a4a96e
1 parent 25c9ec9
commit 0a4a96e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...is-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java b/...is-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java
@@ -53,7 +53,7 @@ public void testDorisSourceProperties() {
         Map<String, String> properties = getAllOptions();
         properties.put("doris.request.query.timeout", "21600s");
         properties.put("doris.request.tablet.size", "1");
-        properties.put("doris.batch.size", "1024");
+        properties.put("doris.batch.size", "4064");
         properties.put("doris.exec.mem.limit", "8192mb");
         properties.put("doris.deserialize.arrow.async", "false");
         properties.put("doris.deserialize.queue.size", "64");
@@ -118,7 +118,7 @@ public void testDorisSinkProperties() {
         Map<String, String> properties = getAllOptions();
         properties.put("doris.request.query.timeout", "21600s");
         properties.put("doris.request.tablet.size", "1");
-        properties.put("doris.batch.size", "1024");
+        properties.put("doris.batch.size", "4064");
         properties.put("doris.exec.mem.limit", "8192mb");
         properties.put("doris.deserialize.arrow.async", "false");
         properties.put("doris.deserialize.queue.size", "64");