[improve](load) pass cancel reason to sink operator when cancelled

kaijchen · Nov 6, 2024 · c0fa66d · c0fa66d
1 parent 84307c5
commit c0fa66d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);