compile in windows

src/client/src/tscLocalMerge.c

@@ -1251,7 +1251,7 @@ bool genFinalResults(SSqlObj *pSql, SLocalReducer *pLocalReducer, bool noMoreCur
   if (tscIsSecondStageQuery(pQueryInfo)) {
     char* pbuf = calloc(1,pResBuf->num * pModel->rowSize);
 
-    doArithmeticCalculate(pQueryInfo, pbuf, pResBuf->data, pResBuf->num);
+    doArithmeticCalculate(pQueryInfo, pbuf, pResBuf->data, (int32_t)pResBuf->num);
     memcpy(pResBuf->data, pbuf, pResBuf->num * pModel->rowSize);
     free(pbuf);
   }

src/client/src/tscSQLParser.c

@@ -1410,7 +1410,7 @@ static int32_t handleArithmeticExpr(SSqlCmd* pCmd, int32_t clauseIndex, int32_t
       // TODO: other error handling
     } END_TRY
 
-    pInfo->pArithExprInfo->base.arg[0].argBytes = tbufTell(&bw);
+    pInfo->pArithExprInfo->base.arg[0].argBytes = (int16_t) tbufTell(&bw);
     pInfo->pArithExprInfo->base.arg[0].argValue.pz = tbufGetData(&bw, true);
     pInfo->pArithExprInfo->base.arg[0].argType = TSDB_DATA_TYPE_BINARY;
     tbufCloseWriter(&bw);

src/client/src/tscServer.c

@@ -789,7 +789,7 @@ int tscBuildQueryMsg(SSqlObj *pSql, SSqlInfo *pInfo) {
 
   if(tscIsSecondStageQuery(pQueryInfo)) {
     size_t output = tscNumOfFields(pQueryInfo);
-    pQueryMsg->secondStageOutput = htonl(output);
+    pQueryMsg->secondStageOutput = htonl((int32_t) output);
 
     SSqlFuncMsg *pSqlFuncExpr1 = (SSqlFuncMsg *)pMsg;