From 9e128b92f809d69bf1ec868dc8491c8047950ba7 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 13 Jul 2023 16:17:18 +0800 Subject: [PATCH] fix recover error --- source/libs/stream/src/streamBackendRocksdb.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index e32ff5681a..0b7d6d7693 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -1494,7 +1494,7 @@ 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); + *pVLen = decodeValueFunc((void*)valStr, vlen, NULL, (char**)pVal); } *pKey = pKtmp->key;