diff --git a/source/util/src/tcompression.c b/source/util/src/tcompression.c
index 525ee71126..fbc080a7f6 100644
--- a/source/util/src/tcompression.c
+++ b/source/util/src/tcompression.c
@@ -1619,7 +1619,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..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 , 1, 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
 
@@ -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