From f23a72b93792712a959c9ca7b817876780e70528 Mon Sep 17 00:00:00 2001 From: zhiqiang Date: Wed, 27 Mar 2024 23:28:05 +0800 Subject: [PATCH] [chore](log) print query id before logging profile in be.INFO (#32922) --- be/src/pipeline/pipeline_fragment_context.cpp | 10 ++++++++-- .../pipeline_x/pipeline_x_fragment_context.cpp | 4 +++- 2 files changed, 11 insertions(+), 3 deletions(-) diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp index 2c38ef9c8909c0..55c5d95bb9882f 100644 --- a/be/src/pipeline/pipeline_fragment_context.cpp +++ b/be/src/pipeline/pipeline_fragment_context.cpp @@ -460,7 +460,11 @@ void PipelineFragmentContext::trigger_report_if_necessary() { // _runtime_state->load_channel_profile()->compute_time_in_profile(); // TODO load channel profile add timer _runtime_state->load_channel_profile()->pretty_print(&ss); } - VLOG_FILE << ss.str(); + + VLOG_FILE << "Query " << print_id(this->get_query_id()) << " fragment " + << this->get_fragment_id() << " instance " + << print_id(this->get_fragment_instance_id()) << " profile:\n" + << ss.str(); } auto st = send_report(false); if (!st.ok()) { @@ -917,7 +921,9 @@ void PipelineFragmentContext::_close_fragment_instance() { if (_runtime_state->load_channel_profile()) { _runtime_state->load_channel_profile()->pretty_print(&ss); } - LOG(INFO) << ss.str(); + + LOG_INFO("Query {} fragment {} instance {} profile:\n {}", print_id(this->_query_id), + this->_fragment_id, print_id(this->get_fragment_instance_id()), ss.str()); } // all submitted tasks done _exec_env->fragment_mgr()->remove_pipeline_context( diff --git a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp index 4419ecbe7f4815..794d67e09f3083 100644 --- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp +++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp @@ -1347,7 +1347,9 @@ void PipelineXFragmentContext::_close_fragment_instance() { if (_runtime_state->load_channel_profile()) { _runtime_state->load_channel_profile()->pretty_print(&ss); } - LOG(INFO) << ss.str(); + + LOG_INFO("Query {} fragment {} profile:\n {}", print_id(this->_query_id), + this->_fragment_id, ss.str()); } // all submitted tasks done _exec_env->fragment_mgr()->remove_pipeline_context(