diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index 1ececd975d..48fa65b690 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -2713,6 +2713,8 @@ static void decompressQueryColData(SSqlRes *pRes, SQueryInfo* pQueryInfo, char *
   }
 
   int32_t tailLen = pRes->rspLen - sizeof(SRetrieveTableRsp) - decompLen;
+  /* Skip compSizes */ 
+  pData += numOfCols * sizeof(int32_t);
   memmove(data + decompLen, pData, tailLen);
   memmove(data, outputBuf, decompLen);