diff --git a/source/libs/parser/src/parInsertData.c b/source/libs/parser/src/parInsertData.c
index c5c4463a95..5fa2961474 100644
--- a/source/libs/parser/src/parInsertData.c
+++ b/source/libs/parser/src/parInsertData.c
@@ -469,7 +469,7 @@ int32_t mergeTableDataBlocks(SHashObj* pHashObj, uint8_t payloadType, SArray** p
       // the maximum expanded size in byte when a row-wise data is converted to SDataRow format
       int32_t expandSize = isRawPayload ? getRowExpandSize(pOneTableBlock->pTableMeta) : 0;
       int64_t destSize = dataBuf->size + pOneTableBlock->size + pBlocks->numOfRows * expandSize +
-                         sizeof(STColumn) * getNumOfColumns(pOneTableBlock->pTableMeta);
+                         sizeof(STColumn) * getNumOfColumns(pOneTableBlock->pTableMeta) + pOneTableBlock->createTbReqLen;
 
       if (dataBuf->nAllocSize < destSize) {
         dataBuf->nAllocSize = (uint32_t)(destSize * 1.5);
diff --git a/tests/script/api/batchprepare.c b/tests/script/api/batchprepare.c
index f3fab0c965..8169e6c503 100644
--- a/tests/script/api/batchprepare.c
+++ b/tests/script/api/batchprepare.c
@@ -233,9 +233,9 @@ CaseCtrl gCaseCtrl = { // default
   .printRes = true,
   .runTimes = 0,
   .caseIdx = -1,
-  .caseNum = -1,
-  .caseRunIdx = -1,
-  .caseRunNum = -1,
+  .caseNum = 1,
+  .caseRunIdx = 11,
+  .caseRunNum = 1,
 };
 #endif