fix

apache · Jan 26, 2025 · d6e500d · d6e500d
1 parent 7dced4f
commit d6e500d
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/be/src/pipeline/pipeline_task.h b/be/src/pipeline/pipeline_task.h
@@ -234,12 +234,14 @@ class PipelineTask {
     bool wake_up_early() const { return _wake_up_early; }
 
     void make_runnable_if_all_downstream_finished() {
-        DCHECK_GE(_sink_shared_state->unfinished_source_counter, 0);
-        if (!_sink_shared_state || _sink_shared_state->unfinished_source_counter != 0) {
+        if (!_sink_shared_state) {
             return;
         }
-        set_wake_up_early();
-        clear_blocking_state();
+        DCHECK_GE(_sink_shared_state->unfinished_source_counter, 0);
+        if (!_sink_shared_state->unfinished_source_counter) {
+            set_wake_up_early();
+            clear_blocking_state();
+        }
     }
 
 private: