From e7ea42635db8437412e21c26c73bc73a8a578da3 Mon Sep 17 00:00:00 2001 From: Evgeniy Shishkin Date: Fri, 10 Oct 2025 12:41:01 +0400 Subject: [PATCH] [BugFix] Fix IN runtime filter to respect FE session variable (#63081) --- be/src/exec/hash_joiner.cpp | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/be/src/exec/hash_joiner.cpp b/be/src/exec/hash_joiner.cpp index 244d32c5e73..5706092bf07 100644 --- a/be/src/exec/hash_joiner.cpp +++ b/be/src/exec/hash_joiner.cpp @@ -556,7 +556,13 @@ Status HashJoiner::_create_runtime_in_filters(RuntimeState* state) { SCOPED_TIMER(build_metrics().build_runtime_filter_timer); size_t ht_row_count = get_ht_row_count(); - if (ht_row_count > config::max_pushdown_conditions_per_column) { + // Use FE session variable if set, otherwise fall back to BE config + size_t max_conditions = config::max_pushdown_conditions_per_column; + if (state->query_options().__isset.max_pushdown_conditions_per_column) { + max_conditions = state->query_options().max_pushdown_conditions_per_column; + } + + if (ht_row_count > max_conditions) { return Status::OK(); }