This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 44090a523bf [debug](log) Add some debug logs (#33237)
44090a523bf is described below
commit 44090a523bfffee5e1de36d65cdd3590478452af
Author: Gabriel <[email protected]>
AuthorDate: Thu Apr 4 16:53:52 2024 +0800
[debug](log) Add some debug logs (#33237)
---
.../pipeline_x/local_exchange/local_exchange_sink_operator.cpp | 6 +++++-
be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 2 +-
2 files changed, 6 insertions(+), 2 deletions(-)
diff --git
a/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
b/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
index 068b8d1701f..e540aeb54b9 100644
--- a/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
+++ b/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
@@ -46,7 +46,11 @@ Status LocalExchangeSinkLocalState::close(RuntimeState*
state, Status exec_statu
}
RETURN_IF_ERROR(Base::close(state, exec_status));
if (exec_status.ok()) {
- DCHECK(_release_count) << "Do not finish correctly! " <<
debug_string(0);
+ DCHECK(_release_count) << "Do not finish correctly! " <<
debug_string(0)
+ << " state: { cancel = " <<
state->is_cancelled() << ", "
+ << state->query_status().to_string() << "}
query ctx: { cancel = "
+ << state->get_query_ctx()->is_cancelled() << ",
"
+ <<
state->get_query_ctx()->exec_status().to_string() << "}";
}
return Status::OK();
}
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 8ba3d6ddf2e..f888500cef6 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
@@ -1332,7 +1332,7 @@ void
PipelineXFragmentContext::close_if_prepare_failed(Status st) {
for (auto& task : _tasks) {
for (auto& t : task) {
DCHECK(!t->is_pending_finish());
- WARN_IF_ERROR(t->close(Status::OK()), "close_if_prepare_failed
failed: ");
+ WARN_IF_ERROR(t->close(st), "close_if_prepare_failed failed: ");
close_a_pipeline();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
