diff --git a/source/dnode/vnode/src/tsdb/tsdbCache.c b/source/dnode/vnode/src/tsdb/tsdbCache.c
index a39c74a679..ab504acea7 100644
--- a/source/dnode/vnode/src/tsdb/tsdbCache.c
+++ b/source/dnode/vnode/src/tsdb/tsdbCache.c
@@ -1955,6 +1955,7 @@ typedef struct SFSNextRowIter {
   SArray                  *pIndexList;
   int32_t                  iBrinIndex;
   SBrinBlock               brinBlock;
+  SBrinBlock              *pBrinBlock;
   int32_t                  iBrinRecord;
   SBrinRecord              brinRecord;
   SBlockData               blockData;
@@ -2143,6 +2144,11 @@ static int32_t getNextRowFromFS(void *iter, TSDBROW **ppRow, bool *pIgnoreEarlie
       pBrinBlk = taosArrayGet(state->pIndexList, state->iBrinIndex);
     }
 
+    if (!state->pBrinBlock) {
+      state->pBrinBlock = &state->brinBlock;
+    } else {
+      tBrinBlockClear(&state->brinBlock);
+    }
     code = tsdbDataFileReadBrinBlock(state->pr->pFileReader, pBrinBlk, &state->brinBlock);
     if (code != TSDB_CODE_SUCCESS) {
       goto _err;
@@ -2420,6 +2426,16 @@ int32_t clearNextRowFromFS(void *iter) {
     state->pBlockData = NULL;
   }
 
+  if (state->pBrinBlock) {
+    tBrinBlockDestroy(state->pBrinBlock);
+    state->pBrinBlock = NULL;
+  }
+
+  if (state->pIndexList) {
+    taosArrayDestroy(state->pIndexList);
+    state->pIndexList = NULL;
+  }
+
   if (state->pTSRow) {
     taosMemoryFree(state->pTSRow);
     state->pTSRow = NULL;