From 5c942d53dd2ab35913d3a2cc7e63e7940ddc09d7 Mon Sep 17 00:00:00 2001
From: Gabriel <gabrielleebuaa@gmail.com>
Date: Fri, 29 Mar 2024 16:58:36 +0800
Subject: [PATCH] udpate

---
 .../local_exchange/local_exchange_sink_operator.cpp           | 4 ++--
 1 file changed, 2 insertions(+), 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
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();
 }