diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index 47d712e51df88a4f9a168ddedbed5cd3eae14bdf..b7a5715544e25b6d288fb69790d8cf7ba7e224db 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -2694,7 +2694,7 @@ static void decompressQueryColData(SSqlRes *pRes, SQueryInfo* pQueryInfo, char *
   for(int32_t i = 0; i < numOfCols; ++i) {
     SInternalField* pInfo = (SInternalField*)TARRAY_GET_ELEM(pQueryInfo->fieldsInfo.internalField, i);
     bufOffset = pInfo->field.bytes * pRes->numOfRows;
-    int32_t flen = (*(tDataTypes[pInfo->field.type].decompFunc))(pData, compSizes[i], pRes->numOfRows, p, bufOffset,
+    int32_t flen = (*(tDataTypes[pInfo->field.type].decompFunc))(pData, htonl(compSizes[i]), pRes->numOfRows, p, bufOffset,
                                                                compressed, NULL, 0);
     p += flen;
     decompLen +=flen;
diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 7b580634918049ded82551e044549f61befdaccb..07c6e12606c89f93bc7ccdacc4de76d34edbc861 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -4216,7 +4216,7 @@ static void doCopyQueryResultToMsg(SQInfo *pQInfo, int32_t numOfRows, char *data
     for (int32_t col = 0; col < numOfCols; ++col) {
       SColumnInfoData* pColRes = taosArrayGet(pRes->pDataBlock, col);
       if (compressed) {
-        compSizes[col] = compressQueryColData(pColRes, pRes->info.rows, data, compressed);
+        compSizes[col] = htonl(compressQueryColData(pColRes, pRes->info.rows, data, compressed));
         data += compSizes[col];
         *compLen += compSizes[col];
       } else {
@@ -4228,7 +4228,7 @@ static void doCopyQueryResultToMsg(SQInfo *pQInfo, int32_t numOfRows, char *data
     for (int32_t col = 0; col < numOfCols; ++col) {
       SColumnInfoData* pColRes = taosArrayGet(pRes->pDataBlock, col);
       if (compressed) {
-        compSizes[col] = compressQueryColData(pColRes, numOfRows, data, compressed);
+        compSizes[col] = htonl(compressQueryColData(pColRes, numOfRows, data, compressed));
         data += compSizes[col];
         *compLen += compSizes[col];
       } else {