diff --git a/include/util/tpagedbuf.h b/include/util/tpagedbuf.h
index d9e233f8bbe7e78c833f8f58ceeed501b6badd9c..4cd0797df31bae159daa3afad8d146206dcb87da 100644
--- a/include/util/tpagedbuf.h
+++ b/include/util/tpagedbuf.h
@@ -152,6 +152,12 @@ bool isAllDataInMemBuf(const SDiskbasedBuf* pBuf);
  */
 void setBufPageDirty(void* pPageInfo, bool dirty);
 
+/**
+ * Set the compress/ no-compress flag for paged buffer, when flushing data in disk.
+ * @param pBuf
+ */
+void setBufPageCompressOnDisk(SDiskbasedBuf* pBuf, bool comp);
+
 /**
  * Print the statistics when closing this buffer
  * @param pBuf
diff --git a/source/libs/executor/src/tlinearhash.c b/source/libs/executor/src/tlinearhash.c
index b644801a6efd595d4a2aa59758da08e6c932b366..152102f0c3edc76c3c75243a92e0bab59ae98f7e 100644
--- a/source/libs/executor/src/tlinearhash.c
+++ b/source/libs/executor/src/tlinearhash.c
@@ -78,6 +78,8 @@ SLHashObj* tHashInit(int32_t inMemPages, int32_t pageSize, _hash_fn_t fn, int32_
     return NULL;
   }
 
+  setBufPageCompressOnDisk(pHashObj->pBuf, false);
+
   /**
    * The number of bits in the hash value, which is used to decide the exact bucket where the object should be located in.
    * The initial value is 0.