From 852052a99beb29bad066e891eb1f2ede50ac4c51 Mon Sep 17 00:00:00 2001 From: slzhou Date: Mon, 15 Apr 2024 07:47:07 +0800 Subject: [PATCH] fix: extracted data block shall initialize pks of datablock info --- source/common/src/tdatablock.c | 14 ++------------ 1 file changed, 2 insertions(+), 12 deletions(-) diff --git a/source/common/src/tdatablock.c b/source/common/src/tdatablock.c index 7a45e44eab..842038e41f 100644 --- a/source/common/src/tdatablock.c +++ b/source/common/src/tdatablock.c @@ -653,25 +653,15 @@ SSDataBlock* blockDataExtractBlock(SSDataBlock* pBlock, int32_t startIndex, int3 return NULL; } - SSDataBlock* pDst = createDataBlock(); + SSDataBlock* pDst = createOneDataBlock(pBlock, false); if (pDst == NULL) { return NULL; } - pDst->info = pBlock->info; - pDst->info.rows = 0; - pDst->info.capacity = 0; - pDst->info.rowSize = 0; - size_t numOfCols = taosArrayGetSize(pBlock->pDataBlock); - for (int32_t i = 0; i < numOfCols; ++i) { - SColumnInfoData colInfo = {0}; - SColumnInfoData* pSrcCol = taosArrayGet(pBlock->pDataBlock, i); - colInfo.info = pSrcCol->info; - blockDataAppendColInfo(pDst, &colInfo); - } blockDataEnsureCapacity(pDst, rowCount); + size_t numOfCols = taosArrayGetSize(pBlock->pDataBlock); for (int32_t i = 0; i < numOfCols; ++i) { SColumnInfoData* pColData = taosArrayGet(pBlock->pDataBlock, i); SColumnInfoData* pDstCol = taosArrayGet(pDst->pDataBlock, i);