From 0bf98096c907605ed6f8fa9656c3321234aa4904 Mon Sep 17 00:00:00 2001 From: Minglei Jin Date: Wed, 22 Mar 2023 10:57:27 +0800 Subject: [PATCH] fix(tsdb/cache): init isLast once for each fileset --- source/dnode/vnode/src/tsdb/tsdbCache.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbCache.c b/source/dnode/vnode/src/tsdb/tsdbCache.c index e78127e195..6fc8ad8be6 100644 --- a/source/dnode/vnode/src/tsdb/tsdbCache.c +++ b/source/dnode/vnode/src/tsdb/tsdbCache.c @@ -636,6 +636,7 @@ static int32_t getNextRowFromFSLast(void *iter, TSDBROW **ppRow, bool *pIgnoreEa for (int i = 0; i < state->pLoadInfo->numOfStt; ++i) { state->pLoadInfo[i].colIds = aCols; state->pLoadInfo[i].numOfCols = nCols; + state->pLoadInfo[i].isLast = isLast; } tMergeTreeOpen(&state->mergeTree, 1, *state->pDataFReader, state->suid, state->uid, &(STimeWindow){.skey = state->lastTs, .ekey = TSKEY_MAX}, @@ -647,10 +648,9 @@ static int32_t getNextRowFromFSLast(void *iter, TSDBROW **ppRow, bool *pIgnoreEa if (nCols != state->pLoadInfo->numOfCols) { for (int i = 0; i < state->pLoadInfo->numOfStt; ++i) { state->pLoadInfo[i].numOfCols = nCols; - } - state->pLoadInfo->checkRemainingRow = state->checkRemainingRow; - state->pLoadInfo->isLast = isLast; + state->pLoadInfo[i].checkRemainingRow = state->checkRemainingRow; + } } bool hasVal = tMergeTreeNext(&state->mergeTree); if (!hasVal) { -- GitLab