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(); }