This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new e7489e247f0 branch-4.0: [opt](var) change merge_io_read_slice_size to
merge_io_read_slice_size_bytes #57272 (#57273)
e7489e247f0 is described below
commit e7489e247f00e7c346a05d8e807958220ab3e9da
Author: Mingyu Chen (Rayner) <[email protected]>
AuthorDate: Fri Oct 24 10:54:34 2025 +0800
branch-4.0: [opt](var) change merge_io_read_slice_size to
merge_io_read_slice_size_bytes #57272 (#57273)
bp #57272
---
.../nereids/trees/plans/commands/info/SetSessionVarOp.java | 10 ++++++++++
.../src/main/java/org/apache/doris/qe/SessionVariable.java | 9 +++++----
2 files changed, 15 insertions(+), 4 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/SetSessionVarOp.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/SetSessionVarOp.java
index 83e094dfd3b..3356ee3a878 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/SetSessionVarOp.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/SetSessionVarOp.java
@@ -120,6 +120,16 @@ public class SetSessionVarOp extends SetVarOp {
}
}
+ if
(name.equalsIgnoreCase(SessionVariable.MERGE_IO_READ_SLICE_SIZE_BYTES)) {
+ try {
+ this.value = new StringLiteral(
+
Long.toString(ParseUtil.analyzeDataVolume(value.getStringValue())));
+ } catch (Throwable t) {
+ // see comments of FILE_SPLIT_SIZE
+ this.value = new StringLiteral(value.getStringValue());
+ }
+ }
+
if (name.equalsIgnoreCase("is_report_success")) {
name = SessionVariable.ENABLE_PROFILE;
}
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 eb32fe14fca..79762f9d154 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
@@ -868,7 +868,7 @@ public class SessionVariable implements Serializable,
Writable {
public static final String MULTI_DISTINCT_STRATEGY =
"multi_distinct_strategy";
public static final String AGG_PHASE = "agg_phase";
- public static final String MERGE_IO_READ_SLICE_SIZE =
"merge_io_read_slice_size";
+ public static final String MERGE_IO_READ_SLICE_SIZE_BYTES =
"merge_io_read_slice_size_bytes";
public static final String ENABLE_PREFER_CACHED_ROWSET =
"enable_prefer_cached_rowset";
public static final String QUERY_FRESHNESS_TOLERANCE_MS =
"query_freshness_tolerance_ms";
@@ -2589,9 +2589,10 @@ public class SessionVariable implements Serializable,
Writable {
public int aggPhase = 0;
- @VariableMgr.VarAttr(name = MERGE_IO_READ_SLICE_SIZE, description = {"调整
READ_SLICE_SIZE 大小，降低 Merge IO 读放大影响",
+ @VariableMgr.VarAttr(name = MERGE_IO_READ_SLICE_SIZE_BYTES, description = {
+ "调整 READ_SLICE_SIZE 大小，降低 Merge IO 读放大影响",
"Make the READ_SLICE_SIZE variable configurable to reduce the
impact caused by read amplification."})
- public int mergeReadSliceSize = 8388608;
+ public int mergeReadSliceSizeBytes = 8388608;
public void setAggPhase(int phase) {
aggPhase = phase;
@@ -4751,7 +4752,7 @@ public class SessionVariable implements Serializable,
Writable {
tResult.setHnswEfSearch(hnswEFSearch);
tResult.setHnswCheckRelativeDistance(hnswCheckRelativeDistance);
tResult.setHnswBoundedQueue(hnswBoundedQueue);
- tResult.setMergeReadSliceSize(mergeReadSliceSize);
+ tResult.setMergeReadSliceSize(mergeReadSliceSizeBytes);
return tResult;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
