diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 1be13a8f6777690179955bc8e8487b52314ac476..7cc8a1c5916af544b428033437675ce6bc121017 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -5369,7 +5369,7 @@ static void doSecondaryArithmeticProcess(SQuery* pQuery) {
       }
     } else {
       pArithSup->pArithExpr = pExpr;
-      tExprTreeCalcTraverse(pArithSup->pArithExpr->pExpr, pQuery->rec.rows, data[i]->data, pArithSup, TSDB_ORDER_ASC,
+      tExprTreeCalcTraverse(pArithSup->pArithExpr->pExpr, (int32_t)pQuery->rec.rows, data[i]->data, pArithSup, TSDB_ORDER_ASC,
                             getArithemicInputSrc);
     }
   }