This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 3485b7d9047 [fix](stream-load) fix query id is zero in stream load
log (#33954)
3485b7d9047 is described below
commit 3485b7d9047aad89a8ed303da983d684edc2ee0e
Author: HHoflittlefish777 <[email protected]>
AuthorDate: Mon Apr 22 19:49:32 2024 +0800
[fix](stream-load) fix query id is zero in stream load log (#33954)
---
be/src/runtime/stream_load/stream_load_executor.cpp | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git a/be/src/runtime/stream_load/stream_load_executor.cpp
b/be/src/runtime/stream_load/stream_load_executor.cpp
index 54ad204a879..720c2e86898 100644
--- a/be/src/runtime/stream_load/stream_load_executor.cpp
+++ b/be/src/runtime/stream_load/stream_load_executor.cpp
@@ -69,7 +69,7 @@ Status
StreamLoadExecutor::execute_plan_fragment(std::shared_ptr<StreamLoadConte
#ifndef BE_TEST
ctx->start_write_data_nanos = MonotonicNanos();
LOG(INFO) << "begin to execute stream load. label=" << ctx->label << ",
txn_id=" << ctx->txn_id
- << ", query_id=" <<
print_id(ctx->put_result.params.params.query_id);
+ << ", query_id=" << ctx->id;
Status st;
auto exec_fragment = [ctx, this](RuntimeState* state, Status* status) {
if (ctx->group_commit) {
@@ -111,7 +111,6 @@ Status
StreamLoadExecutor::execute_plan_fragment(std::shared_ptr<StreamLoadConte
}
}
LOG(WARNING) << "fragment execute failed"
- << ", query_id=" <<
UniqueId(ctx->put_result.params.params.query_id)
<< ", err_msg=" << status->to_string() << ", " <<
ctx->brief();
// cancel body_sink, make sender known it
if (ctx->body_sink != nullptr) {
@@ -150,8 +149,7 @@ Status
StreamLoadExecutor::execute_plan_fragment(std::shared_ptr<StreamLoadConte
}
LOG(INFO) << "finished to execute stream load. label=" << ctx->label
- << ", txn_id=" << ctx->txn_id
- << ", query_id=" <<
print_id(ctx->put_result.params.params.query_id)
+ << ", txn_id=" << ctx->txn_id << ", query_id=" << ctx->id
<< ", receive_data_cost_ms="
<< (ctx->receive_and_read_data_cost_nanos -
ctx->read_data_cost_nanos) / 1000000
<< ", read_data_cost_ms=" << ctx->read_data_cost_nanos /
1000000
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
