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
index c9de0d23227329..068b8d1701f019 100644
--- 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();
 }