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 78b63d46c06 [improve](load) pass cancel reason to tablet writer when
cancelled (#43388)
78b63d46c06 is described below
commit 78b63d46c068704eec9ca2ba7e1db8459b422f24
Author: Kaijie Chen <c...@apache.org>
AuthorDate: Fri Nov 8 21:36:59 2024 +0800
[improve](load) pass cancel reason to tablet writer when cancelled (#43388)
---
be/src/pipeline/exec/operator.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/exec/operator.cpp
b/be/src/pipeline/exec/operator.cpp
index fb2dd828c39..3b5174d87c0 100644
--- a/be/src/pipeline/exec/operator.cpp
+++ b/be/src/pipeline/exec/operator.cpp
@@ -666,7 +666,7 @@ Status AsyncWriterSink<Writer, Parent>::close(RuntimeState*
state, Status exec_s
if (_writer) {
Status st = _writer->get_writer_status();
if (exec_status.ok()) {
- _writer->force_close(state->is_cancelled() ?
Status::Cancelled("Cancelled")
+ _writer->force_close(state->is_cancelled() ? state->cancel_reason()
:
Status::Cancelled("force close"));
} else {
_writer->force_close(exec_status);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
