diff --git a/source/dnode/vnode/src/inc/tsdb.h b/source/dnode/vnode/src/inc/tsdb.h
index 6263703c011d596040572b04d29d1a331ed3e18b..f41592fe46d966f727dd74ebd174a5430a26e82d 100644
--- a/source/dnode/vnode/src/inc/tsdb.h
+++ b/source/dnode/vnode/src/inc/tsdb.h
@@ -502,6 +502,7 @@ struct SDelIdx {
 
 struct SDiskDataHdr {
   uint32_t delimiter;
+  uint32_t fmtVer;
   int64_t  suid;
   int64_t  uid;
   int32_t  szUid;
diff --git a/source/dnode/vnode/src/tsdb/tsdbReaderWriter.c b/source/dnode/vnode/src/tsdb/tsdbReaderWriter.c
index 324db5b11185b0bad7ef845c9c4dc4db5cc9f6d6..55ef576916d9bf52e972afa5363692c228f85aea 100644
--- a/source/dnode/vnode/src/tsdb/tsdbReaderWriter.c
+++ b/source/dnode/vnode/src/tsdb/tsdbReaderWriter.c
@@ -1426,6 +1426,7 @@ int32_t tsdbWriteBlockData(SDataFWriter *pWriter, SBlockData *pBlockData, SBlock
 
   // ================= DATA ====================
   SDiskDataHdr hdr = {.delimiter = TSDB_FILE_DLMT,
+                      .fmtVer = 0,
                       .suid = pBlockData->suid,
                       .uid = pBlockData->uid,
                       .nRow = pBlockData->nRow,
diff --git a/source/dnode/vnode/src/tsdb/tsdbSnapshot.c b/source/dnode/vnode/src/tsdb/tsdbSnapshot.c
index 81c5190a3280528b1de0f2c8a2a7411fbd8595c2..29a64cf0b5b24bbe78ab9f81f1623f7c344b061d 100644
--- a/source/dnode/vnode/src/tsdb/tsdbSnapshot.c
+++ b/source/dnode/vnode/src/tsdb/tsdbSnapshot.c
@@ -27,8 +27,10 @@ struct STsdbSnapReader {
   int32_t       fid;
   SDataFReader* pDataFReader;
   SArray*       aBlockIdx;  // SArray<SBlockIdx>
+  SArray*       aBlockL;    // SArray<SBlockL>
   int32_t       iBlockIdx;
   SBlockIdx*    pBlockIdx;
+  int32_t       iBlockL;
   SMapData      mBlock;  // SMapData<SBlock>
   int32_t       iBlock;
   SBlockData    oBlockData;
@@ -43,32 +45,37 @@ struct STsdbSnapReader {
 
 static int32_t tsdbSnapReadData(STsdbSnapReader* pReader, uint8_t** ppData) {
   int32_t code = 0;
-#if 0
   STsdb*  pTsdb = pReader->pTsdb;
 
   while (true) {
     if (pReader->pDataFReader == NULL) {
-      SDFileSet* pSet =
-          taosArraySearch(pReader->fs.aDFileSet, &(SDFileSet){.fid = pReader->fid}, tDFileSetCmprFn, TD_GT);
-
+      // next
+      SDFileSet  dFileSet = {.fid = pReader->fid};
+      SDFileSet* pSet = taosArraySearch(pReader->fs.aDFileSet, &dFileSet, tDFileSetCmprFn, TD_GT);
       if (pSet == NULL) goto _exit;
-
       pReader->fid = pSet->fid;
+
+      // load
       code = tsdbDataFReaderOpen(&pReader->pDataFReader, pReader->pTsdb, pSet);
       if (code) goto _err;
 
-      // SBlockIdx
       code = tsdbReadBlockIdx(pReader->pDataFReader, pReader->aBlockIdx);
       if (code) goto _err;
 
+      code = tsdbReadBlockL(pReader->pDataFReader, pReader->aBlockL);
+      if (code) goto _err;
+
+      // init
       pReader->iBlockIdx = 0;
       pReader->pBlockIdx = NULL;
+      pReader->iBlockL = 0;
 
       tsdbInfo("vgId:%d, vnode snapshot tsdb open data file to read for %s, fid:%d", TD_VID(pTsdb->pVnode), pTsdb->path,
                pReader->fid);
     }
 
     while (true) {
+#if 0
       if (pReader->pBlockIdx == NULL) {
         if (pReader->iBlockIdx >= taosArrayGetSize(pReader->aBlockIdx)) {
           tsdbDataFReaderClose(&pReader->pDataFReader);
@@ -149,14 +156,15 @@ static int32_t tsdbSnapReadData(STsdbSnapReader* pReader, uint8_t** ppData) {
 
         tPutBlockData((uint8_t*)(&pId[1]), &pReader->nBlockData);
 
-        tsdbInfo("vgId:%d, vnode snapshot read data for %s, fid:%d suid:%" PRId64 " uid:%" PRId64
-                 " iBlock:%d minVersion:%d maxVersion:%d nRow:%d out of %d size:%d",
-                 TD_VID(pTsdb->pVnode), pTsdb->path, pReader->fid, pReader->pBlockIdx->suid, pReader->pBlockIdx->uid,
-                 pReader->iBlock - 1, pBlock->minVersion, pBlock->maxVersion, pReader->nBlockData.nRow, pBlock->nRow,
-                 size);
+        // tsdbInfo("vgId:%d, vnode snapshot read data for %s, fid:%d suid:%" PRId64 " uid:%" PRId64
+        //          " iBlock:%d minVersion:%d maxVersion:%d nRow:%d out of %d size:%d",
+        //          TD_VID(pTsdb->pVnode), pTsdb->path, pReader->fid, pReader->pBlockIdx->suid, pReader->pBlockIdx->uid,
+        //          pReader->iBlock - 1, pBlock->minVersion, pBlock->maxVersion, pReader->nBlockData.nRow, pBlock->nRow,
+        //          size);
 
         goto _exit;
       }
+#endif
     }
   }
 
@@ -166,7 +174,6 @@ _exit:
 _err:
   tsdbError("vgId:%d, vnode snapshot tsdb read data for %s failed since %s", TD_VID(pTsdb->pVnode), pTsdb->path,
             tstrerror(code));
-#endif
   return code;
 }
 
@@ -294,6 +301,11 @@ int32_t tsdbSnapReaderOpen(STsdb* pTsdb, int64_t sver, int64_t ever, int8_t type
     code = TSDB_CODE_OUT_OF_MEMORY;
     goto _err;
   }
+  pReader->aBlockL = taosArrayInit(0, sizeof(SBlockL));
+  if (pReader->aBlockL == NULL) {
+    code = TSDB_CODE_OUT_OF_MEMORY;
+    goto _err;
+  }
   pReader->mBlock = tMapDataInit();
   code = tBlockDataCreate(&pReader->oBlockData);
   if (code) goto _err;
@@ -329,6 +341,7 @@ int32_t tsdbSnapReaderClose(STsdbSnapReader** ppReader) {
   if (pReader->pDataFReader) {
     tsdbDataFReaderClose(&pReader->pDataFReader);
   }
+  taosArrayDestroy(pReader->aBlockL);
   taosArrayDestroy(pReader->aBlockIdx);
   tMapDataClear(&pReader->mBlock);
   tBlockDataDestroy(&pReader->oBlockData, 1);
diff --git a/source/dnode/vnode/src/tsdb/tsdbUtil.c b/source/dnode/vnode/src/tsdb/tsdbUtil.c
index fd39d559ea9f02f6123d94c12aa8958b04370b44..f324124a9c0b329b180e8ae2a8a4a8e2bc99c0ea 100644
--- a/source/dnode/vnode/src/tsdb/tsdbUtil.c
+++ b/source/dnode/vnode/src/tsdb/tsdbUtil.c
@@ -1549,6 +1549,7 @@ int32_t tPutDiskDataHdr(uint8_t *p, void *ph) {
   SDiskDataHdr *pHdr = (SDiskDataHdr *)ph;
 
   n += tPutU32(p ? p + n : p, pHdr->delimiter);
+  n += tPutU32v(p ? p + n : p, pHdr->fmtVer);
   n += tPutI64(p ? p + n : p, pHdr->suid);
   n += tPutI64(p ? p + n : p, pHdr->uid);
   n += tPutI32v(p ? p + n : p, pHdr->szUid);
@@ -1566,6 +1567,7 @@ int32_t tGetDiskDataHdr(uint8_t *p, void *ph) {
   SDiskDataHdr *pHdr = (SDiskDataHdr *)ph;
 
   n += tGetU32(p + n, &pHdr->delimiter);
+  n += tGetU32v(p + n, &pHdr->fmtVer);
   n += tGetI64(p + n, &pHdr->suid);
   n += tGetI64(p + n, &pHdr->uid);
   n += tGetI32v(p + n, &pHdr->szUid);