[fix](sink) fix memory leak in VNodeChannel (apache#15834) (apache#15835

) Signed-off-by: freemandealer <[email protected]> Signed-off-by: freemandealer <[email protected]>
HappenLee · Jan 12, 2023 · f3ef3f7 · f3ef3f7
1 parent 8841988
commit f3ef3f7
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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;