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 1a14bde317..512bcda8fa 100644
--- a/src/sql/engine/px/datahub/components/ob_dh_winbuf.h
+++ b/src/sql/engine/px/datahub/components/ob_dh_winbuf.h
@@ -105,6 +105,7 @@ public:
     : ObPieceMsgCtx(op_id, task_cnt, timeout_ts), received_(0),
                     tenant_id_(tenant_id), whole_msg_() {}
   ~ObWinbufPieceMsgCtx() = default;
+  virtual void destroy() { whole_msg_.reset(); }
   INHERIT_TO_STRING_KV("meta", ObPieceMsgCtx, K_(received));
   static int alloc_piece_msg_ctx(const ObWinbufPieceMsg &pkt,
                                  ObPxCoordInfo &coord_info,
diff --git a/src/sql/engine/px/datahub/ob_dh_msg_ctx.h b/src/sql/engine/px/datahub/ob_dh_msg_ctx.h
index 2f25c2b8f9..831d53f028 100644
--- a/src/sql/engine/px/datahub/ob_dh_msg_ctx.h
+++ b/src/sql/engine/px/datahub/ob_dh_msg_ctx.h
@@ -25,6 +25,7 @@ class ObPieceMsgCtx
 public:
   ObPieceMsgCtx(uint64_t op_id, int64_t task_cnt, int64_t timeout_ts)
       : op_id_(op_id), task_cnt_(task_cnt), timeout_ts_(timeout_ts) {}
+  virtual ~ObPieceMsgCtx() {}
   VIRTUAL_TO_STRING_KV(K_(op_id), K_(task_cnt));
   virtual void destroy() {}
   uint64_t op_id_;    // 哪个算子使用 datahub 服务
@@ -42,6 +43,7 @@ public:
     for (int i = 0; i < ctxs_.count(); ++i) {
       if (OB_NOT_NULL(ctxs_[i])) {
         ctxs_[i]->destroy();
+        ctxs_[i]->~ObPieceMsgCtx();
       }
     }
     ctxs_.reset();