fix

JNSimba · Aug 9, 2024 · e58833b · e58833b
1 parent b1f502a
commit e58833b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java
@@ -209,7 +209,7 @@ public void testTableBatch() throws Exception {
                                 + " 'sink.enable-delete' = 'true',"
                                 + " 'sink.flush.queue-size' = '2',"
                                 + " 'sink.buffer-flush.max-rows' = '100000',"
-                                + " 'sink.buffer-flush.max-bytes' = '5000000',"
+                                + " 'sink.buffer-flush.max-bytes' = '50MB',"
                                 + " 'sink.buffer-flush.interval' = '10s'"
                                 + ")",
                         getFenodes(),
@@ -296,7 +296,7 @@ public void testTableGroupCommit() throws Exception {
                                 + " 'sink.enable-delete' = 'true',"
                                 + " 'sink.flush.queue-size' = '2',"
                                 + " 'sink.buffer-flush.max-rows' = '300000',"
-                                + " 'sink.buffer-flush.max-bytes' = '5000000',"
+                                + " 'sink.buffer-flush.max-bytes' = '50MB',"
                                 + " 'sink.buffer-flush.interval' = '10s'"
                                 + ")",
                         getFenodes(),