diff --git a/omnioperator/omniop-spark-extension-ock/cpp/src/shuffle/ock_merge_reader.cpp b/omnioperator/omniop-spark-extension-ock/cpp/src/shuffle/ock_merge_reader.cpp
index fe21d3347e9de3778f11a2892a9dde91a131b50b..d8b53dd71f46c639ad280f4514f975d9f0eb1a4f 100644
--- a/omnioperator/omniop-spark-extension-ock/cpp/src/shuffle/ock_merge_reader.cpp
+++ b/omnioperator/omniop-spark-extension-ock/cpp/src/shuffle/ock_merge_reader.cpp
@@ -15,12 +15,15 @@ using namespace ock::dopspark;
 bool OckMergeReader::Initialize(const int32_t *typeIds, uint32_t colNum)
 {
     mColNum = colNum;
-    mVectorBatch = new (std::nothrow) VBDataDesc(colNum);
+    mVectorBatch = std::make_shares<VBDataDesc>();
     if (UNLIKELY(mVectorBatch == nullptr)) {
         LOG_ERROR("Failed to new instance for vector batch description");
         return false;
     }
 
+    if (UNLIKELY(!mVectorBatch->Initialize(colNum))) {
+        LOG_ERROR()
+    }
     mColTypeIds.reserve(colNum);
     for (uint32_t index = 0; index < colNum; ++index) {
         mColTypeIds.emplace_back(typeIds[index]);