From 679102a7f61b308e3f4e78057ee45aa6dc81028a Mon Sep 17 00:00:00 2001 From: changyuwei <2017501503@qq.com> Date: Wed, 26 Jul 2023 00:41:00 +0800 Subject: [PATCH] [opt](hive)opt select count(*) stmt push down agg on hive --- be/src/vec/exec/format/orc/vorc_reader.cpp | 1 - be/src/vec/exec/scan/vscan_node.cpp | 4 ++++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/be/src/vec/exec/format/orc/vorc_reader.cpp b/be/src/vec/exec/format/orc/vorc_reader.cpp index 6ee3815cef15ecf..c78450fd3ecd6f5 100644 --- a/be/src/vec/exec/format/orc/vorc_reader.cpp +++ b/be/src/vec/exec/format/orc/vorc_reader.cpp @@ -1385,7 +1385,6 @@ Status OrcReader::get_next_block(Block* block, size_t* read_rows, bool* eof) { if (get_remaining_rows() == 0) { *eof = true; } - *read_rows = rows; return Status::OK(); } diff --git a/be/src/vec/exec/scan/vscan_node.cpp b/be/src/vec/exec/scan/vscan_node.cpp index 28d47da52cc4f58..8381603cfacfe33 100644 --- a/be/src/vec/exec/scan/vscan_node.cpp +++ b/be/src/vec/exec/scan/vscan_node.cpp @@ -114,6 +114,10 @@ Status VScanNode::init(const TPlanNode& tnode, RuntimeState* state) { _max_pushdown_conditions_per_column = config::max_pushdown_conditions_per_column; } + // tnode.olap_scan_node.push_down_agg_type_opt field is deprecated + // Introduced a new field : tnode.push_down_agg_type_opt + // + // make it compatible here if (tnode.__isset.push_down_agg_type_opt) { _push_down_agg_type = tnode.push_down_agg_type_opt; } else if (tnode.olap_scan_node.__isset.push_down_agg_type_opt) {