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 8bde14f73e2 [chore](log) print query id before logging profile in
be.INFO (#32922)
8bde14f73e2 is described below
commit 8bde14f73e2feedfdb5589077b22149a0e375ede
Author: zhiqiang <[email protected]>
AuthorDate: Wed Mar 27 23:28:05 2024 +0800
[chore](log) print query id before logging profile in be.INFO (#32922)
---
be/src/pipeline/pipeline_fragment_context.cpp | 10 ++++++++--
be/src/pipeline/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 8600a98b32c..0e075b90ebc 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -459,7 +459,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 5ed5dc8d598..93edf737c18 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
@@ -1351,7 +1351,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(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
