This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit aed858a44207162132c6a20afd7e1f27c7b54e58 Author: zhangstar333 <[email protected]> AuthorDate: Sun Feb 4 22:01:50 2024 +0800 [improve](log) print query_id when fold constant on BE (#30802) --- be/src/runtime/fold_constant_executor.cpp | 2 ++ be/src/vec/exec/vpartition_sort_node.cpp | 22 ++++++++++++---------- 2 files changed, 14 insertions(+), 10 deletions(-) diff --git a/be/src/runtime/fold_constant_executor.cpp b/be/src/runtime/fold_constant_executor.cpp index 0a501b979b5..33fb034b60a 100644 --- a/be/src/runtime/fold_constant_executor.cpp +++ b/be/src/runtime/fold_constant_executor.cpp @@ -46,6 +46,7 @@ #include "util/binary_cast.hpp" #include "util/defer_op.h" #include "util/runtime_profile.h" +#include "util/uid_util.h" #include "vec/columns/column.h" #include "vec/columns/column_vector.h" #include "vec/columns/columns_number.h" @@ -69,6 +70,7 @@ Status FoldConstantExecutor::fold_constant_vexpr(const TFoldConstantParams& para TQueryGlobals query_globals = params.query_globals; _query_id = params.query_id; + LOG(INFO) << "fold_query_id: " << print_id(_query_id); // init RETURN_IF_ERROR(_init(query_globals, params.query_options)); // only after init operation, _mem_tracker is ready diff --git a/be/src/vec/exec/vpartition_sort_node.cpp b/be/src/vec/exec/vpartition_sort_node.cpp index 772156b9880..f1a2341ac86 100644 --- a/be/src/vec/exec/vpartition_sort_node.cpp +++ b/be/src/vec/exec/vpartition_sort_node.cpp @@ -205,17 +205,19 @@ Status VPartitionSortNode::_emplace_into_hash_table(const ColumnRawPtrs& key_col _value_places.push_back(mapped); _num_partition++; }; - - SCOPED_TIMER(_emplace_key_timer); - for (size_t row = 0; row < num_rows; ++row) { - auto& mapped = - agg_method.lazy_emplace(state, row, creator, creator_for_null_key); - mapped->add_row_idx(row); + { + SCOPED_TIMER(_emplace_key_timer); + for (size_t row = 0; row < num_rows; ++row) { + auto& mapped = + agg_method.lazy_emplace(state, row, creator, creator_for_null_key); + mapped->add_row_idx(row); + } } - - SCOPED_TIMER(_selector_block_timer); - for (auto* place : _value_places) { - RETURN_IF_ERROR(place->append_block_by_selector(input_block, eos)); + { + SCOPED_TIMER(_selector_block_timer); + for (auto* place : _value_places) { + RETURN_IF_ERROR(place->append_block_by_selector(input_block, eos)); + } } return Status::OK(); }, --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
