From 8e11adc3fb073cea258678f1d845bc88ccc20ca4 Mon Sep 17 00:00:00 2001 From: zhiqiang-hhhh Date: Mon, 29 Jan 2024 12:32:32 +0800 Subject: [PATCH 1/3] N --- fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 1 + 1 file changed, 1 insertion(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java index 783323b03fac72..af9b5f981feb83 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java @@ -350,6 +350,7 @@ private Map getSummaryInfo(boolean isFinished) { } builder.taskState(!isFinished && context.getState().getStateType().equals(MysqlStateType.OK) ? "RUNNING" : context.getState().toString()); + LOG.info("Query {} state {}", DebugUtil.printId(context.queryId()), context.getState().toString()); builder.user(context.getQualifiedUser()); builder.defaultDb(context.getDatabase()); builder.workloadGroup(context.getWorkloadGroupName()); From 4ba28b9c6dfecce42caadaf169fba5e423a36e59 Mon Sep 17 00:00:00 2001 From: zhiqiang-hhhh Date: Mon, 29 Jan 2024 12:37:41 +0800 Subject: [PATCH 2/3] N --- fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 1 - 1 file changed, 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java index af9b5f981feb83..783323b03fac72 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java @@ -350,7 +350,6 @@ private Map getSummaryInfo(boolean isFinished) { } builder.taskState(!isFinished && context.getState().getStateType().equals(MysqlStateType.OK) ? "RUNNING" : context.getState().toString()); - LOG.info("Query {} state {}", DebugUtil.printId(context.queryId()), context.getState().toString()); builder.user(context.getQualifiedUser()); builder.defaultDb(context.getDatabase()); builder.workloadGroup(context.getWorkloadGroupName()); From f35f8686ee79758ace841ea83ca5ee54c71ef83b Mon Sep 17 00:00:00 2001 From: zhiqiang-hhhh Date: Wed, 27 Mar 2024 20:38:13 +0800 Subject: [PATCH 3/3] OPT LOG --- 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 8600a98b32cc15..0e075b90ebca64 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 5ed5dc8d59808e..93edf737c18f19 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(