From 359a8b271b1edd1609487ecfb8640e818814962f Mon Sep 17 00:00:00 2001 From: wujianchao5 Date: Fri, 26 Jun 2026 17:28:23 +0800 Subject: [PATCH] [fix](chore) some configuration comments --- be/src/common/config.cpp | 2 +- be/src/common/config.h | 2 +- .../src/main/java/org/apache/doris/qe/SessionVariable.java | 6 +++--- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/be/src/common/config.cpp b/be/src/common/config.cpp index b521fa57ec3dfd..4f680ae8b86d72 100644 --- a/be/src/common/config.cpp +++ b/be/src/common/config.cpp @@ -749,7 +749,7 @@ DEFINE_mInt32(memory_gc_sleep_time_ms, "500"); // max write buffer size before flush, default 200MB DEFINE_mInt64(write_buffer_size, "209715200"); DEFINE_mBool(enable_adaptive_write_buffer_size, "true"); -// max buffer size used in memtable for the aggregated table, default 400MB +// max buffer size used in memtable for the aggregated table, default 100MB DEFINE_mInt64(write_buffer_size_for_agg, "104857600"); DEFINE_mInt64(min_write_buffer_size_for_partial_update, "1048576"); // max parallel flush task per memtable writer diff --git a/be/src/common/config.h b/be/src/common/config.h index 0b415ed5d2c4ae..b614f6913c2098 100644 --- a/be/src/common/config.h +++ b/be/src/common/config.h @@ -807,7 +807,7 @@ DECLARE_mInt32(memory_gc_sleep_time_ms); // max write buffer size before flush, default 200MB DECLARE_mInt64(write_buffer_size); DECLARE_mBool(enable_adaptive_write_buffer_size); -// max buffer size used in memtable for the aggregated table, default 400MB +// max buffer size used in memtable for the aggregated table, default 100MB DECLARE_mInt64(write_buffer_size_for_agg); DECLARE_mInt64(min_write_buffer_size_for_partial_update); diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java index 2870c3443fefd8..70a5770d61396d 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java @@ -300,9 +300,9 @@ public String toString() { public static final String DELETE_WITHOUT_PARTITION = "delete_without_partition"; - // set the default parallelism for send batch when execute InsertStmt operation, - // if the value for parallelism exceed `max_send_batch_parallelism_per_job` in BE config, - // then the coordinator be will use the value of `max_send_batch_parallelism_per_job` + // Set the default parallelism for send batch when execute InsertStmt operation. + // The actual concurrency is bounded by the shared BE `send_batch_thread_pool` + // (see BE config `send_batch_thread_pool_thread_num`). public static final String SEND_BATCH_PARALLELISM = "send_batch_parallelism"; // turn off all automatic join reorder algorithms