You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by kx...@apache.org on 2023/06/21 16:39:11 UTC
[doris] branch master updated: [fix](log) fix the too large warning log of BE (#21027)
This is an automated email from the ASF dual-hosted git repository.
kxiao 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 49bbe88327 [fix](log) fix the too large warning log of BE (#21027)
49bbe88327 is described below
commit 49bbe88327806e12a18e7490f5262e7a01e8ccff
Author: zclllyybb <zh...@selectdb.com>
AuthorDate: Thu Jun 22 00:39:04 2023 +0800
[fix](log) fix the too large warning log of BE (#21027)
---
be/src/pipeline/pipeline_fragment_context.cpp | 9 ++++++---
be/src/pipeline/task_scheduler.cpp | 7 +++++--
2 files changed, 11 insertions(+), 5 deletions(-)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp
index 9ecea24228..89231b026a 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -154,9 +154,12 @@ void PipelineFragmentContext::cancel(const PPlanFragmentCancelReason& reason,
_runtime_state->set_is_cancelled(true);
LOG(WARNING) << "PipelineFragmentContext Canceled. reason=" << msg;
- for (auto& task : _tasks) {
- LOG(WARNING) << task->debug_string();
- }
+
+ // Print detail informations below when you debugging here.
+ //
+ // for (auto& task : _tasks) {
+ // LOG(WARNING) << task->debug_string();
+ // }
_runtime_state->set_process_status(_exec_status);
// Get pipe from new load stream manager and send cancel to it or the fragment may hang to wait read from pipe
diff --git a/be/src/pipeline/task_scheduler.cpp b/be/src/pipeline/task_scheduler.cpp
index 5a00ff364c..06baaaecaa 100644
--- a/be/src/pipeline/task_scheduler.cpp
+++ b/be/src/pipeline/task_scheduler.cpp
@@ -278,8 +278,11 @@ void TaskScheduler::_do_work(size_t index) {
task->set_previous_core_id(index);
if (!status.ok()) {
- LOG(WARNING) << fmt::format("Pipeline task failed. reason: {}, task: \n{}",
- status.to_string(), task->debug_string());
+ LOG(WARNING) << fmt::format("Pipeline task failed. reason: {}", status.to_string());
+ // Print detail informations below when you debugging here.
+ //
+ // LOG(WARNING)<< "task:\n"<<task->debug_string();
+
// exec failed，cancel all fragment instance
fragment_ctx->cancel(PPlanFragmentCancelReason::INTERNAL_ERROR, status.to_string());
fragment_ctx->send_report(true);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org