[BugFix] Fix IN runtime filter to respect FE session variable (#63081)

This commit is contained in:
Evgeniy Shishkin 2025-10-10 12:41:01 +04:00 committed by GitHub
parent 2c23586802
commit e7ea42635d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 1 deletions

View File

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