From 31f4cb5eb4506e2d37119447d95a5de9321d3ab7 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Fri, 1 Nov 2024 09:46:09 +0800
Subject: [PATCH 1/2] fix possible crash

---
 source/util/src/tcompression.c           | 5 ++++-
 tests/script/tsim/compress/commitlog.sim | 9 ++++++++-
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/source/util/src/tcompression.c b/source/util/src/tcompression.c
index 9c9ded693e..7ef35bebaf 100644
--- a/source/util/src/tcompression.c
+++ b/source/util/src/tcompression.c
@@ -1617,7 +1617,10 @@ int32_t tsDecompressBigint(void *pIn, int32_t nIn, int32_t nEle, void *pOut, int
         uTrace("encode:%s, compress:%s, level:%d, type:%s, l1:%d", compressL1Dict[l1].name, compressL2Dict[l2].name,  \
                lvl, tDataTypes[type].name, l1);                                                                       \
         int32_t len = compressL1Dict[l1].comprFn(pIn, nEle, pBuf, type);                                              \
-        int8_t  alvl = tsGetCompressL2Level(l2, lvl);                                                                 \
+        if (len < 0) {                                                                                                \
+          return len;                                                                                                 \
+        }                                                                                                             \
+        int8_t alvl = tsGetCompressL2Level(l2, lvl);                                                                  \
         return compressL2Dict[l2].comprFn(pBuf, len, pOut, nOut, type, alvl);                                         \
       } else {                                                                                                        \
         uTrace("dencode:%s, decompress:%s, level:%d, type:%s", compressL1Dict[l1].name, compressL2Dict[l2].name, lvl, \
diff --git a/tests/script/tsim/compress/commitlog.sim b/tests/script/tsim/compress/commitlog.sim
index 38899b95ba..c936d8be46 100644
--- a/tests/script/tsim/compress/commitlog.sim
+++ b/tests/script/tsim/compress/commitlog.sim
@@ -20,7 +20,7 @@ sql create table $tb (ts timestamp, b bool, t tinyint, s smallint, i int, big bi
 $count = 0
 while $count < $N
    $ms = 1591200000000 + $count
-   sql insert into $tb values(  $ms , 1, 0, $count , $count , $count ,'it is a string')
+   sql insert into $tb values(  $ms , $count/256, 0, $count , $count , $count ,'it is a string')
    $count = $count + 1
 endw
 
@@ -29,6 +29,13 @@ if $rows != $N then
   return -1
 endi
 
+sql flush database $db
+
+sql select * from $tb
+if $rows != $N then
+  return -1
+endi
+
 print =============== step2
 $i = 1
 $db = $dbPrefix . $i

From d6f1d0853c39e3355d6e4a7d176526445156c7dc Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Fri, 1 Nov 2024 09:50:35 +0800
Subject: [PATCH 2/2] change test case

---
 tests/script/tsim/compress/commitlog.sim | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/script/tsim/compress/commitlog.sim b/tests/script/tsim/compress/commitlog.sim
index c936d8be46..d0380dd559 100644
--- a/tests/script/tsim/compress/commitlog.sim
+++ b/tests/script/tsim/compress/commitlog.sim
@@ -20,7 +20,7 @@ sql create table $tb (ts timestamp, b bool, t tinyint, s smallint, i int, big bi
 $count = 0
 while $count < $N
    $ms = 1591200000000 + $count
-   sql insert into $tb values(  $ms , $count/256, 0, $count , $count , $count ,'it is a string')
+   sql insert into $tb values(  $ms , 10, 0, $count , $count , $count ,'it is a string')
    $count = $count + 1
 endw