This is an automated email from the ASF dual-hosted git repository.
englefly pushed a commit to branch rf-max-rowcount
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 4bccc0687b1c5a829b19cfbe4815e60ca2116692
Author: minghong <zhoumingh...@selectdb.com>
AuthorDate: Mon May 26 15:32:18 2025 +0800
set runtimeFilterMaxBuildRowCount
---
fe/fe-core/src/main/java/org/apache/doris/qe/CoordinatorContext.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java | 3 +++
gensrc/thrift/PaloInternalService.thrift | 1 +
3 files changed, 5 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/qe/CoordinatorContext.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/CoordinatorContext.java
index c9266cf6add..6e0edc64bf7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/CoordinatorContext.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/CoordinatorContext.java
@@ -335,7 +335,7 @@ public class CoordinatorContext {
}
queryOptions.setFeProcessUuid(ExecuteEnv.getInstance().getProcessUUID());
queryOptions.setMysqlRowBinaryFormat(context.getCommand() ==
MysqlCommand.COM_STMT_EXECUTE);
-
+
queryOptions.setRuntimeFilterMaxBuildRowCount(context.getSessionVariable().runtimeFilterMaxBuildRowCount);
setOptionsFromUserProperty(context, queryOptions);
return queryOptions;
}
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 6feadb229a7..07fe8319799 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
@@ -1311,6 +1311,9 @@ public class SessionVariable implements Serializable,
Writable {
@VariableMgr.VarAttr(name = ENABLE_SYNC_RUNTIME_FILTER_SIZE, needForward =
true, fuzzy = true)
private boolean enableSyncRuntimeFilterSize = true;
+ @VariableMgr.VarAttr(name = "runtime_filter_max_build_row_count",
needForward = true, fuzzy = false)
+ public long runtimeFilterMaxBuildRowCount = 64L * 1024L * 1024L;
+
@VariableMgr.VarAttr(name = ENABLE_PARALLEL_RESULT_SINK, needForward =
true, fuzzy = true)
private boolean enableParallelResultSink = false;
diff --git a/gensrc/thrift/PaloInternalService.thrift
b/gensrc/thrift/PaloInternalService.thrift
index 81e4d1f877c..30f1e8f7c83 100644
--- a/gensrc/thrift/PaloInternalService.thrift
+++ b/gensrc/thrift/PaloInternalService.thrift
@@ -394,6 +394,7 @@ struct TQueryOptions {
163: optional bool inverted_index_compatible_read = false
164: optional bool check_orc_init_sargs_success = false
165: optional i32 exchange_multi_blocks_byte_size = 262144
+ 166: optional i64 runtime_filter_max_build_row_count = 67108864 //64M
// For cloud, to control if the content would be written into file cache
// In write path, to control if the content would be written into file cache.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
