From e73129fda5ad59ec36ac47fc1ea9532dd698f995 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Fri, 6 Jan 2023 17:38:18 +0800
Subject: [PATCH] refactor: do some internal refactor.

---
 source/util/src/tcompression.c | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/source/util/src/tcompression.c b/source/util/src/tcompression.c
index e4ca936d22..b4c3ecd12a 100644
--- a/source/util/src/tcompression.c
+++ b/source/util/src/tcompression.c
@@ -284,6 +284,7 @@ int32_t tsDecompressINTImp(const char *const input, const int32_t nelements, cha
         int64_t* p = (int64_t*) output;
 
         if (selector == 0 || selector == 1) {
+#if 0
           int32_t batch = elems >> 2;
           int32_t remainder = elems & 0x3;
           int32_t gBatch = (nelements - count) >> 2;
@@ -305,6 +306,10 @@ int32_t tsDecompressINTImp(const char *const input, const int32_t nelements, cha
           }
 
           count += minRemain;
+#endif
+          for (int32_t i = 0; i < elems && count < nelements; i++, count++) {
+            p[_pos++] = prev_value;
+          }
         } else {
           int32_t batch = elems >> 2;
           int32_t remain = elems & 0x03;