diff --git a/source/dnode/vnode/src/inc/tsdb.h b/source/dnode/vnode/src/inc/tsdb.h index 88b80f0eef..8cf316e9e5 100644 --- a/source/dnode/vnode/src/inc/tsdb.h +++ b/source/dnode/vnode/src/inc/tsdb.h @@ -305,6 +305,7 @@ struct STbData { TSKEY maxKey; int64_t minVersion; int64_t maxVersion; + int32_t maxSkmVer; SDelData *pHead; SDelData *pTail; SMemSkipList sl; diff --git a/source/dnode/vnode/src/tsdb/tsdbMemTable.c b/source/dnode/vnode/src/tsdb/tsdbMemTable.c index bb0d087333..a50125cc4b 100644 --- a/source/dnode/vnode/src/tsdb/tsdbMemTable.c +++ b/source/dnode/vnode/src/tsdb/tsdbMemTable.c @@ -333,6 +333,7 @@ static int32_t tsdbGetOrCreateTbData(SMemTable *pMemTable, tb_uid_t suid, tb_uid pTbData->maxKey = TSKEY_MIN; pTbData->minVersion = VERSION_MAX; pTbData->maxVersion = VERSION_MIN; + pTbData->maxSkmVer = -1; pTbData->pHead = NULL; pTbData->pTail = NULL; pTbData->sl.seed = taosRand(); @@ -562,6 +563,7 @@ static int32_t tsdbInsertTableDataImpl(SMemTable *pMemTable, STbData *pTbData, i pTbData->minVersion = TMIN(pTbData->minVersion, version); pTbData->maxVersion = TMAX(pTbData->maxVersion, version); + pTbData->maxSkmVer = TMAX(pTbData->maxSkmVer, pMsgIter->sversion); // SMemTable pMemTable->minKey = TMIN(pMemTable->minKey, pTbData->minKey);