This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new c6a3432602e [Chore](execution) update
PARALLEL_EXCHANGE_INSTANCE_NUM/BATCH_SIZE default value (#60141)
c6a3432602e is described below
commit c6a3432602ea0eede63483f4b8c30de84b04b6e4
Author: Pxl <[email protected]>
AuthorDate: Mon Jan 26 16:17:45 2026 +0800
[Chore](execution) update PARALLEL_EXCHANGE_INSTANCE_NUM/BATCH_SIZE default
value (#60141)
Increasing the batch_size will result in an overall performance
improvement of approximately 5% in Doris (some operators become slower,
while others become faster).
This pull request makes adjustments to the default configuration values
in the `SessionVariable` class to improve query parallelism and batch
processing efficiency. The changes increase the maximum number of
parallel exchange instances and the default batch size.
Configuration defaults updated:
* Increased the default value of `exchangeInstanceParallel` from 100 to
256, allowing for more parallel exchange instances during query
execution.
* Increased the default value of `batchSize` from 4064 to 8160, enabling
larger batch processing in queries.
---
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 8325de0a46e..a6e9eadc668 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
@@ -1213,7 +1213,7 @@ public class SessionVariable implements Serializable,
Writable {
public String lcTimeNames = "en_US";
@VariableMgr.VarAttr(name = PARALLEL_EXCHANGE_INSTANCE_NUM)
- public int exchangeInstanceParallel = 100;
+ public int exchangeInstanceParallel = 256;
@VariableMgr.VarAttr(name = SQL_SAFE_UPDATES)
public int sqlSafeUpdates = 0;
@@ -1227,7 +1227,7 @@ public class SessionVariable implements Serializable,
Writable {
// 4096 minus 16 + 16 bytes padding that in padding pod array
@VariableMgr.VarAttr(name = BATCH_SIZE, fuzzy = true, checker =
"checkBatchSize", needForward = true)
- public int batchSize = 4064;
+ public int batchSize = 8160;
// 16352 + 16 + 16 = 16384
@VariableMgr.VarAttr(name = BROKER_LOAD_BATCH_SIZE, fuzzy = true, checker
= "checkBatchSize")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
