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 index aa3d00dae..2bd9b8905 100644 --- 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 @@ -208,9 +208,9 @@ public void testTableBatch() throws Exception { + " 'sink.enable.batch-mode' = 'true'," + " 'sink.enable-delete' = 'true'," + " 'sink.flush.queue-size' = '2'," - + " 'sink.buffer-flush.max-rows' = '1'," - + " 'sink.buffer-flush.max-bytes' = '5'," - + " 'sink.buffer-flush.interval' = '10s'" + + " 'sink.buffer-flush.max-rows' = '10000'," + + " 'sink.buffer-flush.max-bytes' = '10MB'," + + " 'sink.buffer-flush.interval' = '1s'" + ")", getFenodes(), DATABASE + "." + TABLE_CSV_BATCH_TBL, @@ -295,9 +295,9 @@ public void testTableGroupCommit() throws Exception { + " 'sink.enable.batch-mode' = 'true'," + " 'sink.enable-delete' = 'true'," + " 'sink.flush.queue-size' = '2'," - + " 'sink.buffer-flush.max-rows' = '3'," - + " 'sink.buffer-flush.max-bytes' = '5000'," - + " 'sink.buffer-flush.interval' = '10s'" + + " 'sink.buffer-flush.max-rows' = '10000'," + + " 'sink.buffer-flush.max-bytes' = '10MB'," + + " 'sink.buffer-flush.interval' = '1s'" + ")", getFenodes(), DATABASE + "." + TABLE_GROUP_COMMIT,