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 9bb149b3bef024e82534d6d359be04c4515525ac 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]
