diff --git a/be/src/vec/exec/scan/vfile_scanner.cpp b/be/src/vec/exec/scan/vfile_scanner.cpp index 9353887799207dd..0373dc2804bbec2 100644 --- a/be/src/vec/exec/scan/vfile_scanner.cpp +++ b/be/src/vec/exec/scan/vfile_scanner.cpp @@ -827,6 +827,7 @@ Status VFileScanner::_get_next_reader() { _should_enable_file_meta_cache() ? ExecEnv::GetInstance()->file_meta_cache() : nullptr, _state->query_options().enable_parquet_lazy_mat); + parquet_reader->set_push_down_agg_type(_get_push_down_agg_type()); { SCOPED_TIMER(_open_reader_timer); RETURN_IF_ERROR(parquet_reader->open()); @@ -892,6 +893,7 @@ Status VFileScanner::_get_next_reader() { _profile, _state, *_params, range, _state->query_options().batch_size, _state->timezone(), _io_ctx.get(), _state->query_options().enable_orc_lazy_mat, unsupported_pushdown_types); + orc_reader->set_push_down_agg_type(_get_push_down_agg_type()); if (push_down_predicates) { RETURN_IF_ERROR(_process_late_arrival_conjuncts()); }