[BugFix] Fix SenderQueue may leak closure

the last chunks may hold the closure for rpc. direct return may cause
leak closure when _is_cancelled is true

Signed-off-by: stdpain <drfeng08@gmail.com>

be/src/runtime/sender_queue.cpp

@@ -766,13 +766,15 @@ Status DataStreamRecvr::PipelineSenderQueue::add_chunks(const PTransmitChunkPara
                 // We cannot early-return for short circuit, it may occur for parts of parallelism,
                 // and the other parallelism may need to proceed.
             }
-            if (_is_cancelled) {
-                clean_buffer_queues();
-                return Status::OK();
-            }
+
             _recvr->_num_buffered_bytes += chunk_bytes;
             COUNTER_ADD(_recvr->_peak_buffer_mem_bytes, chunk_bytes);
         }
+
+        if (_is_cancelled) {
+            clean_buffer_queues();
+            return Status::OK();
+        }
     }
 
     return Status::OK();