From e8e87dfc144ff0d28d5f2d73292fb46c8c954591 Mon Sep 17 00:00:00 2001
From: raywill <hustos@gmail.com>
Date: Mon, 30 Aug 2021 14:33:43 +0800
Subject: [PATCH] deal with datahub memory leak

---
 src/sql/engine/px/datahub/components/ob_dh_winbuf.h | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/sql/engine/px/datahub/components/ob_dh_winbuf.h b/src/sql/engine/px/datahub/components/ob_dh_winbuf.h
index f4c502aae9..c4ab067ebd 100644
--- a/src/sql/engine/px/datahub/components/ob_dh_winbuf.h
+++ b/src/sql/engine/px/datahub/components/ob_dh_winbuf.h
@@ -52,7 +52,9 @@ public:
   {}
   ~ObWinbufPieceMsg() = default;
   void reset()
-  {}
+  {
+    deseria_allocator_.reset();
+  }
   INHERIT_TO_STRING_KV("meta", ObDatahubPieceMsg<dtl::ObDtlMsgType::DH_WINBUF_PIECE_MSG>, K_(op_id));
 
 public:
@@ -89,6 +91,7 @@ public:
     is_datum_ = false;
     row_store_.reset();
     datum_store_.reset();
+    assign_allocator_.reset();
   }
   VIRTUAL_TO_STRING_KV(K_(ready_state));
   int ready_state_;
-- 
GitLab