From 15f9e1e29e1d116224cf1633ebc4f4b60bf0a08e Mon Sep 17 00:00:00 2001
From: Yihao Deng <luomoxyz@126.com>
Date: Wed, 17 Apr 2024 08:38:46 +0000
Subject: [PATCH] add compress

---
 source/libs/stream/src/streamBackendRocksdb.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index f06dc368bd..f66eacde6c 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -1615,9 +1615,9 @@ int32_t valueDecode(void* value, int32_t vlen, int64_t* ttl, char** dest) {
     }
     if (key.compress == 1) {
       char* pCompressData = NULL;
-      if (key.len != 0 && *dest != NULL) {
+      if (key.len != 0) {
         p = taosDecodeBinary(p, (void**)&pCompressData, key.len);
-        *dest = taosMemoryCalloc(1, key.rawLen);
+        if (*dest) *dest = taosMemoryCalloc(1, key.rawLen);
         int32_t decompressSize = LZ4_decompress_safe(pCompressData, *dest, key.len, key.rawLen);
         ASSERT(decompressSize == key.rawLen);
         key.len = decompressSize;