From 53ff6edad7e6b346984320a0db7ea98265099c54 Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Fri, 2 Jun 2023 19:03:34 +0800 Subject: [PATCH] fix bug --- source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c | 2 +- source/dnode/vnode/src/tsdb/dev/tsdbMerge.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c b/source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c index 48f49c2fdd..27ec7242d8 100644 --- a/source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c +++ b/source/dnode/vnode/src/tsdb/dev/tsdbDataFileRW.c @@ -456,7 +456,7 @@ static int32_t tsdbDataFileWriteDataBlock(SDataFileWriter *writer, SBlockData *b code = TARRAY2_APPEND_PTR(writer->dataBlkArray, dataBlk); TSDB_CHECK_CODE(code, lino, _exit); - tBlockDataClear(writer->bData); + tBlockDataClear(bData); _exit: if (code) { diff --git a/source/dnode/vnode/src/tsdb/dev/tsdbMerge.c b/source/dnode/vnode/src/tsdb/dev/tsdbMerge.c index 730dfc97a6..aefbfd345b 100644 --- a/source/dnode/vnode/src/tsdb/dev/tsdbMerge.c +++ b/source/dnode/vnode/src/tsdb/dev/tsdbMerge.c @@ -176,7 +176,7 @@ static int32_t tsdbMergeToDataTableBegin(SMerger *merger) { merger->ctx->bDataIdx = 0; for (int32_t i = 0; i < ARRAY_SIZE(merger->ctx->bData); i++) { - code = tBlockDataInit(merger->ctx->bData, merger->ctx->tbid, merger->skmTb->pTSchema, NULL, 0); + code = tBlockDataInit(merger->ctx->bData + i, merger->ctx->tbid, merger->skmTb->pTSchema, NULL, 0); TSDB_CHECK_CODE(code, lino, _exit); }