From 25ce3a951f043c2527166352c3d7e41cd828a1aa Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Thu, 30 Jun 2022 07:00:24 +0000 Subject: [PATCH] fix file corrupted --- source/dnode/vnode/src/tsdb/tsdbReaderWriter.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbReaderWriter.c b/source/dnode/vnode/src/tsdb/tsdbReaderWriter.c index 08d10196eb..163477792e 100644 --- a/source/dnode/vnode/src/tsdb/tsdbReaderWriter.c +++ b/source/dnode/vnode/src/tsdb/tsdbReaderWriter.c @@ -794,7 +794,7 @@ static int32_t tsdbReadColDataImpl(SDataFReader *pReader, SBlockIdx *pBlockIdx, SBlockCol blockCol; SBlockCol *pBlockCol = &blockCol; SColData *pColData; - for (int32_t iCol = 0; iCol < nCol; iCol++) { + for (int32_t iCol = 1; iCol < nCol; iCol++) { int16_t cid = aColId[iCol]; if (tMapDataSearch(&pSubBlock->mBlockCol, &(SBlockCol){.cid = cid}, tGetBlockCol, tBlockColCmprFn, pBlockCol) == @@ -809,7 +809,8 @@ static int32_t tsdbReadColDataImpl(SDataFReader *pReader, SBlockIdx *pBlockIdx, if (code) goto _err; } } else { - offset = pSubBlock->offset + sizeof(SBlockDataHdr) + pSubBlock->vsize + pSubBlock->ksize + pBlockCol->offset; + offset = pSubBlock->offset + sizeof(SBlockDataHdr) + pSubBlock->vsize + pSubBlock->ksize + sizeof(TSCKSUM) + + pBlockCol->offset; size = pBlockCol->bsize + pBlockCol->csize + sizeof(TSCKSUM); code = tsdbRealloc(ppBuf1, size);