From 13077767865134b60f91ebc6dbf37ba8e74d2acb Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 13 Jul 2023 16:09:34 +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 c33d11cd38..e32ff5681a 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -883,7 +883,7 @@ int32_t decodeValueFunc(void* value, int32_t vlen, int64_t* ttl, char** dest) { SStreamValue key = {0}; char* p = value; if (streamStateValueIsStale(p)) { - *dest = NULL; + if (dest != NULL) *dest = NULL; return -1; } p = taosDecodeFixedI64(p, &key.unixTimestamp);