[fix](cancel) Fix wrong status when query failed (#38982)

Pipeline task A failed with `Status A`, pipeline task B should also fail with same `Status A` instead of just returning a CANCELLED.
apache · Aug 16, 2024 · b5c9324 · b5c9324
1 parent 5645dc5
commit b5c9324
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/be/src/runtime/runtime_state.h b/be/src/runtime/runtime_state.h
@@ -729,9 +729,11 @@ class RuntimeState {
     std::string _s3_error_log_file_path;
 };
 
-#define RETURN_IF_CANCELLED(state)                                                    \
-    do {                                                                              \
-        if (UNLIKELY((state)->is_cancelled())) return Status::Cancelled("Cancelled"); \
+#define RETURN_IF_CANCELLED(state)               \
+    do {                                         \
+        if (UNLIKELY((state)->is_cancelled())) { \
+            return (state)->cancel_reason();     \
+        }                                        \
     } while (false)
 
 } // namespace doris