This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
commit 0d9d95a6555634406ac76df5172cfc7c99436ed2 Author: morningman <[email protected]> AuthorDate: Mon Dec 19 12:11:46 2022 +0800 [cherry-pick](statistics) fix missing scanBytes and scanRows in query statistic #14828 --- be/src/vec/exec/vexchange_node.cpp | 6 ++++++ be/src/vec/exec/vexchange_node.h | 1 + 2 files changed, 7 insertions(+) diff --git a/be/src/vec/exec/vexchange_node.cpp b/be/src/vec/exec/vexchange_node.cpp index c9cc87d6bd..8da3d2ead4 100644 --- a/be/src/vec/exec/vexchange_node.cpp +++ b/be/src/vec/exec/vexchange_node.cpp @@ -99,6 +99,12 @@ Status VExchangeNode::get_next(RuntimeState* state, Block* block, bool* eos) { return status; } +Status VExchangeNode::collect_query_statistics(QueryStatistics* statistics) { + RETURN_IF_ERROR(ExecNode::collect_query_statistics(statistics)); + statistics->merge(_sub_plan_query_statistics_recvr.get()); + return Status::OK(); +} + Status VExchangeNode::close(RuntimeState* state) { if (is_closed()) { return Status::OK(); diff --git a/be/src/vec/exec/vexchange_node.h b/be/src/vec/exec/vexchange_node.h index 5e2d4533af..b985097ca6 100644 --- a/be/src/vec/exec/vexchange_node.h +++ b/be/src/vec/exec/vexchange_node.h @@ -36,6 +36,7 @@ public: virtual Status open(RuntimeState* state) override; virtual Status get_next(RuntimeState* state, RowBatch* row_batch, bool* eos) override; virtual Status get_next(RuntimeState* state, Block* row_batch, bool* eos) override; + Status collect_query_statistics(QueryStatistics* statistics) override; virtual Status close(RuntimeState* state) override; // Status collect_query_statistics(QueryStatistics* statistics) override; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
