From f3ef3f7e151d14a0c64c9f295acc722d595ccd97 Mon Sep 17 00:00:00 2001
From: zhengyu <freeman.zhang1992@gmail.com>
Date: Thu, 12 Jan 2023 09:24:51 +0800
Subject: [PATCH] [fix](sink) fix memory leak in VNodeChannel (#15834) (#15835)

Signed-off-by: freemandealer <freeman.zhang1992@gmail.com>

Signed-off-by: freemandealer <freeman.zhang1992@gmail.com>
---
 be/src/vec/sink/vtablet_sink.cpp | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/be/src/vec/sink/vtablet_sink.cpp b/be/src/vec/sink/vtablet_sink.cpp
index 7f756aff83..32bb070d22 100644
--- a/be/src/vec/sink/vtablet_sink.cpp
+++ b/be/src/vec/sink/vtablet_sink.cpp
@@ -175,6 +175,12 @@ VNodeChannel::VNodeChannel(VOlapTableSink* parent, IndexChannel* index_channel,
 }
 
 VNodeChannel::~VNodeChannel() {
+    if (_open_closure != nullptr) {
+        if (_open_closure->unref()) {
+            delete _open_closure;
+        }
+        _open_closure = nullptr;
+    }
     if (_add_block_closure != nullptr) {
         delete _add_block_closure;
         _add_block_closure = nullptr;