From 9434b4eaaceb8cc7592c0271b70fad6e92181713 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 13 Jul 2023 16:07:58 +0800 Subject: [PATCH] fix recover error --- source/libs/stream/src/streamBackendRocksdb.c | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 6012051fd8..c33d11cd38 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -1492,8 +1492,7 @@ int32_t streamStateGetKVByCur_rocksdb(SStreamStateCur* pCur, SWinKey* pKey, cons } if (pVLen != NULL) { - size_t vlen = 0; - + size_t vlen = 0; const char* valStr = rocksdb_iter_value(pCur->iter, &vlen); *pVLen = decodeValueFunc((void*)valStr, vlen, NULL, (char**)&pVal); }