This is an automated email from the ASF dual-hosted git repository.
liaoxin pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 445e196041d [improve](load) pass cancel reason to tablet writer when
cancelled (#43388) (#44131)
445e196041d is described below
commit 445e196041d86096778ab5a75b40f4f390cbb120
Author: Kaijie Chen <[email protected]>
AuthorDate: Mon Nov 18 14:11:38 2024 +0800
[improve](load) pass cancel reason to tablet writer when cancelled (#43388)
(#44131)
backport #43388
---
be/src/pipeline/pipeline_x/operator.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/pipeline_x/operator.cpp
b/be/src/pipeline/pipeline_x/operator.cpp
index 6c2c2a6294d..7820a8d0ef0 100644
--- a/be/src/pipeline/pipeline_x/operator.cpp
+++ b/be/src/pipeline/pipeline_x/operator.cpp
@@ -624,7 +624,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() ?
Status::Cancelled(state->cancel_reason())
:
Status::Cancelled("force close"));
} else {
_writer->force_close(exec_status);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
