fix asan bug

This commit is contained in:
liuyao 2023-04-17 11:48:08 +08:00
parent dc78233f86
commit afc8e5cea7
1 changed files with 1 additions and 0 deletions

View File

@ -445,6 +445,7 @@ int32_t recoverSnapshot(SStreamFileState* pFileState) {
code = streamStateGetKVByCur_rocksdb(pCur, pNewPos->pKey, (const void**)&pVal, &pVLen);
if (code != TSDB_CODE_SUCCESS || pFileState->getTs(pNewPos->pKey) < pFileState->flushMark) {
destroyRowBuffPos(pNewPos);
tdListPopTail(pFileState->usedBuffs);
break;
}
memcpy(pNewPos->pRowBuff, pVal, pVLen);