This is an automated email from the ASF dual-hosted git repository.
lihaopeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 1c49d0076b7 [Debug](exec) Add Debug log for topn (#51614)
1c49d0076b7 is described below
commit 1c49d0076b7f25dd3d2016a0a03ff521b0c15d4c
Author: HappenLee <happen...@selectdb.com>
AuthorDate: Tue Jun 10 22:18:45 2025 +0800
[Debug](exec) Add Debug log for topn (#51614)
---
be/src/pipeline/dependency.cpp | 10 ++++++++++
be/src/service/internal_service.cpp | 4 ++++
2 files changed, 14 insertions(+)
diff --git a/be/src/pipeline/dependency.cpp b/be/src/pipeline/dependency.cpp
index 2325fba17e3..d66377f9413 100644
--- a/be/src/pipeline/dependency.cpp
+++ b/be/src/pipeline/dependency.cpp
@@ -478,6 +478,16 @@ Status
MaterializationSharedState::merge_multi_response(vectorized::Block* block
for (int i = 0; i < block_order_results.size(); ++i) {
for (auto& [backend_id, rpc_struct] : rpc_struct_map) {
vectorized::Block partial_block;
+ if (rpc_struct.callback->response_->blocks_size() <= i) {
+ LOG(WARNING) << "backend id:" << backend_id << " response
block size is not match"
+ << "
rpc_struct.callback->response_->blocks_size()="
+ << rpc_struct.callback->response_->blocks_size()
+ << " blocks=" << block_order_results.size()
+ << " query_id=" <<
print_id(rpc_struct.request.query_id())
+ << " status=" << rpc_status.status().to_string();
+ return Status::InternalError("backend id:" +
std::to_string(backend_id) +
+ " response block size is not
match");
+ }
RETURN_IF_ERROR(
partial_block.deserialize(rpc_struct.callback->response_->blocks(i).block()));
diff --git a/be/src/service/internal_service.cpp
b/be/src/service/internal_service.cpp
index debe9d012d2..53bb5d7df16 100644
--- a/be/src/service/internal_service.cpp
+++ b/be/src/service/internal_service.cpp
@@ -2122,6 +2122,10 @@ void
PInternalService::multiget_data_v2(google::protobuf::RpcController* control
Status st = RowIdStorageReader::read_by_rowids(*request,
response);
st.to_protobuf(response->mutable_status());
LOG(INFO) << "multiget_data finished, cost(us):" <<
watch.elapsed_time() / 1000;
+ LOG(INFO) << "query_id: " << print_id(request->query_id())
+ << " backend id: " <<
BackendOptions::get_backend_id()
+ << " response status:" << st.to_string()
+ << " return block size:" << response->blocks_size();
},
nullptr));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
