fix recover error

This commit is contained in:
yihaoDeng 2023-07-13 16:07:58 +08:00
parent 2361048bed
commit 9434b4eaac
1 changed files with 1 additions and 2 deletions

View File

@ -1493,7 +1493,6 @@ int32_t streamStateGetKVByCur_rocksdb(SStreamStateCur* pCur, SWinKey* pKey, cons
if (pVLen != NULL) {
size_t vlen = 0;
const char* valStr = rocksdb_iter_value(pCur->iter, &vlen);
*pVLen = decodeValueFunc((void*)valStr, vlen, NULL, (char**)&pVal);
}