fix

apache · Dec 10, 2024 · 6153160 · 6153160
1 parent 12cede3
commit 6153160
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/be/src/pipeline/pipeline_task.cpp b/be/src/pipeline/pipeline_task.cpp
@@ -364,7 +364,7 @@ Status PipelineTask::execute(bool* eos) {
         if (!*eos) {
             SCOPED_TIMER(_get_block_timer);
             _get_block_counter->update(1);
-            auto st = _root->get_block_after_projects(_state, block, eos);
+            RETURN_IF_ERROR(_root->get_block_after_projects(_state, block, eos));
         }
 
         if (_block->rows() != 0 || *eos) {
@@ -467,12 +467,11 @@ Status PipelineTask::close(Status exec_status, bool close_sink) {
         SCOPED_RAW_TIMER(&close_ns);
         if (close_sink) {
             s = _sink->close(_state, exec_status);
-        } else {
-            for (auto& op : _operators) {
-                auto tem = op->close(_state);
-                if (!tem.ok() && s.ok()) {
-                    s = tem;
-                }
+        }
+        for (auto& op : _operators) {
+            auto tem = op->close(_state);
+            if (!tem.ok() && s.ok()) {
+                s = tem;
             }
         }
     }