diff --git a/source/dnode/vnode/src/inc/tsdb.h b/source/dnode/vnode/src/inc/tsdb.h
index fe6ecdcbb1422ae94aa32ab421cba4d3e0c61d44..4f22ce768ff75238a928fe87e0ff7d916337d45d 100644
--- a/source/dnode/vnode/src/inc/tsdb.h
+++ b/source/dnode/vnode/src/inc/tsdb.h
@@ -857,8 +857,8 @@ static FORCE_INLINE int tsdbUnLockFS(STsdbFS *pFs) {
 }
 
 struct TSDBROW {
-  int64_t  version;
-  STSRow2 *pRow;
+  int64_t version;
+  STSRow2 tsRow;
 };
 
 struct TSDBKEY {
diff --git a/source/dnode/vnode/src/tsdb/tsdbMemTable2.c b/source/dnode/vnode/src/tsdb/tsdbMemTable2.c
index 049364e9d7a9d9f94412f2599a6025b0f16b2686..aab190b0bb988d0920989326864973f9bd109854 100644
--- a/source/dnode/vnode/src/tsdb/tsdbMemTable2.c
+++ b/source/dnode/vnode/src/tsdb/tsdbMemTable2.c
@@ -81,6 +81,7 @@ int32_t tsdbInsertTableData2(STsdb *pTsdb, int64_t version, SVSubmitBlk *pSubmit
   int32_t    code = 0;
   SMemTable *pMemTable = (SMemTable *)pTsdb->mem;  // TODO
   SMemData  *pMemData;
+  TSDBROW    row = {.version = version};
 
   ASSERT(pMemTable);
 
@@ -95,6 +96,15 @@ int32_t tsdbInsertTableData2(STsdb *pTsdb, int64_t version, SVSubmitBlk *pSubmit
   }
 
   // do insert
+  uint32_t n = 0;
+  uint8_t *p = pSubmitBlk->pData;
+  while (n < pSubmitBlk->nData) {
+    n += tGetTSRow(p + n, &row.tsRow);
+
+    ASSERT(n <= pSubmitBlk->nData);
+
+    // TODO
+  }
 
   return code;