diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index 3e2c2318890671c056b46d9dfce181fec1312e82..05393ab236ef72f5049d148971239aa4cc8dd9da 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -3062,7 +3062,7 @@ int tscProcessRetrieveRspFromNode(SSqlObj *pSql) {
     int32_t numOfCols = pQueryInfo->fieldsInfo.numOfOutput;
 
     TAOS_FIELD *pField = tscFieldInfoGetField(&pQueryInfo->fieldsInfo, numOfCols - 1);
-    int16_t     offset = tscFieldInfoGetOffset(pQueryInfo, numOfCols - 1);
+    int32_t     offset = tscFieldInfoGetOffset(pQueryInfo, numOfCols - 1);
 
     char* p = pRes->data + (pField->bytes + offset) * pRes->numOfRows;
 
diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index ac6b7355d52543727413393f45ca09b581ceab7a..fedb4b90f8bc34aaa6e6176a17c2d009d3936eca 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -264,7 +264,7 @@ static void tscStreamFillTimeGap(SSqlStream* pStream, TSKEY ts) {
     pStream->stime += pStream->slidingTime;
     *(TSKEY*)row[0] =  pStream->stime;
     for (int32_t i = 1; i < pQueryInfo->fieldsInfo.numOfOutput; ++i) {
-      int16_t     offset = tscFieldInfoGetOffset(pQueryInfo, i);
+      int32_t     offset = tscFieldInfoGetOffset(pQueryInfo, i);
       TAOS_FIELD *pField = tscFieldInfoGetField(&pQueryInfo->fieldsInfo, i);
       assignVal(pSql->res.data + offset, (char *)(&pQueryInfo->fillVal[i]), pField->bytes, pField->type);
       row[i] = pSql->res.data + offset;