From 7cec8836b1dbe82c6b397c23df24b8ed403d8279 Mon Sep 17 00:00:00 2001
From: Yihao Deng <luomoxyz@126.com>
Date: Wed, 17 Apr 2024 08:39:43 +0000
Subject: [PATCH] add compress

---
 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 f66eacde6c..c8532bf033 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -1626,9 +1626,8 @@ int32_t valueDecode(void* value, int32_t vlen, int64_t* ttl, char** dest) {
     } else {
       if (key.len != 0 && dest != NULL) p = taosDecodeBinary(p, (void**)dest, key.len);
     }
-
-    if (ttl != NULL) *ttl = key.unixTimestamp == 0 ? 0 : key.unixTimestamp - taosGetTimestampMs();
   }
+  if (ttl != NULL) *ttl = key.unixTimestamp == 0 ? 0 : key.unixTimestamp - taosGetTimestampMs();
 
   return key.len;