diff --git a/source/dnode/vnode/src/tsdb/tsdbCache.c b/source/dnode/vnode/src/tsdb/tsdbCache.c
index e78127e195256e5f1e19e9732197f008926a2e37..6fc8ad8be647c5331f7c31f1e373d891997ece6a 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) {