This is an automated email from the ASF dual-hosted git repository.

mrhhsg pushed a commit to branch adaptive_batch_size
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 1c426b7f3d8be9041ad2d129522c92a7316c587d
Author: Hu Shenggang <[email protected]>
AuthorDate: Thu Apr 9 03:27:20 2026 +0800

    fix regression test cases
---
 .../suites/fault_injection_p0/test_skip_calc_between_segments.groovy   | 3 ++-
 .../suites/load_p0/insert/test_insert_random_distribution_table.groovy | 1 +
 .../suites/unique_with_mow_c_p0/test_compact_multi_segments.groovy     | 3 +++
 .../unique_with_mow_c_p0/test_schema_change_add_key_column.groovy      | 2 ++
 4 files changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/regression-test/suites/fault_injection_p0/test_skip_calc_between_segments.groovy
 
b/regression-test/suites/fault_injection_p0/test_skip_calc_between_segments.groovy
index 5a127335d25..cdfcf5b4df1 100644
--- 
a/regression-test/suites/fault_injection_p0/test_skip_calc_between_segments.groovy
+++ 
b/regression-test/suites/fault_injection_p0/test_skip_calc_between_segments.groovy
@@ -95,7 +95,8 @@ suite("test_skip_calc_between_segments", "nonConcurrent") {
 
     // to cause multi segments
     def customBeConfig = [
-        doris_scanner_row_bytes : 1
+        doris_scanner_row_bytes : 1,
+        enable_adaptive_batch_size: false
     ]
 
     setBeConfigTemporary(customBeConfig) {
diff --git 
a/regression-test/suites/load_p0/insert/test_insert_random_distribution_table.groovy
 
b/regression-test/suites/load_p0/insert/test_insert_random_distribution_table.groovy
index d67b9d9efef..5a1c2112a38 100644
--- 
a/regression-test/suites/load_p0/insert/test_insert_random_distribution_table.groovy
+++ 
b/regression-test/suites/load_p0/insert/test_insert_random_distribution_table.groovy
@@ -42,6 +42,7 @@ suite("test_insert_random_distribution_table", "p0") {
         return
     }
 
+    sql "set preferred_block_size_bytes = 0"
     sql "set batch_size=2"
     // insert first time
     sql "insert into ${tableName} values('2021-11-14', '2', '3', '4', 55), 
('2022-12-13', '3', '31', '4', 55), ('2023-10-14', '23', '45', '66', 88), 
('2023-10-16', '2', '3', '4', 55)"
diff --git 
a/regression-test/suites/unique_with_mow_c_p0/test_compact_multi_segments.groovy
 
b/regression-test/suites/unique_with_mow_c_p0/test_compact_multi_segments.groovy
index b9d3a28bfb6..b28b83d83e8 100644
--- 
a/regression-test/suites/unique_with_mow_c_p0/test_compact_multi_segments.groovy
+++ 
b/regression-test/suites/unique_with_mow_c_p0/test_compact_multi_segments.groovy
@@ -45,13 +45,16 @@ suite("test_compact_multi_segments", "nonConcurrent") {
 
     // batch_size is 4164 in csv_reader.cpp
     // _batch_size is 8192 in vtablet_writer.cpp
+
     def backendId_to_params = get_be_param("doris_scanner_row_bytes")
     onFinish {
         GetDebugPoint().disableDebugPointForAllBEs("MemTable.need_flush")
         set_original_be_param("doris_scanner_row_bytes", backendId_to_params)
+        set_be_param.call("enable_adaptive_batch_size", "true")
     }
     GetDebugPoint().enableDebugPointForAllBEs("MemTable.need_flush")
     set_be_param.call("doris_scanner_row_bytes", "1")
+    set_be_param.call("enable_adaptive_batch_size", "false")
 
     for (int j = 0; j < 2; j++) {
         tableName = "test_compact_multi_segments_" + j
diff --git 
a/regression-test/suites/unique_with_mow_c_p0/test_schema_change_add_key_column.groovy
 
b/regression-test/suites/unique_with_mow_c_p0/test_schema_change_add_key_column.groovy
index f3d9429c747..05cfb7c5795 100644
--- 
a/regression-test/suites/unique_with_mow_c_p0/test_schema_change_add_key_column.groovy
+++ 
b/regression-test/suites/unique_with_mow_c_p0/test_schema_change_add_key_column.groovy
@@ -60,10 +60,12 @@ suite("test_schema_change_add_key_column", "nonConcurrent") 
{
     onFinish {
         GetDebugPoint().clearDebugPointsForAllBEs()
         set_original_be_param("doris_scanner_row_bytes", backendId_to_params)
+        set_be_param.call("enable_adaptive_batch_size", "true")
     }
     GetDebugPoint().enableDebugPointForAllBEs("MemTable.need_flush")
     
GetDebugPoint().enableDebugPointForAllBEs("VBaseSchemaChangeWithSorting._inner_process.create_rowset")
     set_be_param.call("doris_scanner_row_bytes", "1")
+    set_be_param.call("enable_adaptive_batch_size", "false")
 
     // 0: table without sequence_col; add a key col
     // 1: table without sequence_col; reorder cols


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to