diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 605317349dfd989bb248c0c74945b29738eec2e9..406e99f6ef378f4ca1331190b2235b1f6cbe00b1 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -5558,7 +5558,7 @@ static void sequentialTableProcess(SQInfo *pQInfo) {
       pQuery->rec.rows = getNumOfResult(pRuntimeEnv);
 
       int64_t inc = pQuery->rec.rows - prev;
-      pQuery->current->windowResInfo.size += inc;
+      pQuery->current->windowResInfo.size += (int32_t) inc;
 
       // the flag may be set by tableApplyFunctionsOnBlock, clear it here
       CLEAR_QUERY_STATUS(pQuery, QUERY_COMPLETED);