udpate

apache · Mar 29, 2024 · 5c942d5 · 5c942d5
1 parent e73362d
commit 5c942d5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp b/be/src/pipeline/pipeline_x/local_exchange/local_exchange_sink_operator.cpp
@@ -45,8 +45,8 @@ Status LocalExchangeSinkLocalState::close(RuntimeState* state, Status exec_statu
         return Status::OK();
     }
     RETURN_IF_ERROR(Base::close(state, exec_status));
-    if (!_release_count) {
-        _shared_state->sub_running_sink_operators();
+    if (exec_status.ok()) {
+        DCHECK(_release_count) << "Do not finish correctly! " << debug_string(0);
     }
     return Status::OK();
 }