You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ga...@apache.org on 2023/11/28 07:53:52 UTC
(doris) branch master updated: [pipelineX](bug) Add logs (#27665)
This is an automated email from the ASF dual-hosted git repository.
gabriellee 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 c203d363001 [pipelineX](bug) Add logs (#27665)
c203d363001 is described below
commit c203d363001c2b53858d4439c4ac0c091280585e
Author: Gabriel <ga...@gmail.com>
AuthorDate: Tue Nov 28 15:53:40 2023 +0800
[pipelineX](bug) Add logs (#27665)
---
be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
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 6a40f86dede..e65af3d5699 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
@@ -131,6 +131,9 @@ void PipelineXFragmentContext::cancel(const PPlanFragmentCancelReason& reason,
.tag("fragment_id", _fragment_id)
.tag("reason", reason)
.tag("error message", msg);
+ if (reason == PPlanFragmentCancelReason::TIMEOUT) {
+ LOG(WARNING) << "PipelineXFragmentContext is cancelled due to timeout : " << debug_string();
+ }
if (_query_ctx->cancel(true, msg, Status::Cancelled(msg), _fragment_id)) {
if (reason != PPlanFragmentCancelReason::LIMIT_REACH) {
FOR_EACH_RUNTIME_STATE(LOG(WARNING) << "PipelineXFragmentContext cancel instance: "
@@ -149,9 +152,6 @@ void PipelineXFragmentContext::cancel(const PPlanFragmentCancelReason& reason,
// TODO pipeline incomp
// _exec_env->result_queue_mgr()->update_queue_status(id, Status::Aborted(msg));
}
- if (reason == PPlanFragmentCancelReason::TIMEOUT) {
- LOG(WARNING) << "PipelineXFragmentContext is cancelled due to timeout : " << debug_string();
- }
for (auto& tasks : _tasks) {
for (auto& task : tasks) {
task->clear_blocking_state();
@@ -1060,9 +1060,12 @@ std::string PipelineXFragmentContext::debug_string() {
fmt::format_to(debug_string_buffer, "Tasks in instance {}:\n", j);
for (size_t i = 0; i < _tasks[j].size(); i++) {
if (_tasks[j][i]->is_finished()) {
- continue;
+ fmt::format_to(debug_string_buffer, "Task {}: {}\n", i,
+ get_state_name(_tasks[j][i]->get_state()));
+ } else {
+ fmt::format_to(debug_string_buffer, "Task {}: {}\n", i,
+ _tasks[j][i]->debug_string());
}
- fmt::format_to(debug_string_buffer, "Task {}: {}\n", i, _tasks[j][i]->debug_string());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org