diff --git a/src/query/src/qUtil.c b/src/query/src/qUtil.c
index f017c4db1f83b5d8b546188c55448ede7e3d40c3..4caf351799adbf000265566fb22617067efb725d 100644
--- a/src/query/src/qUtil.c
+++ b/src/query/src/qUtil.c
@@ -34,7 +34,7 @@ int32_t getRowNumForMultioutput(SQueryAttr* pQueryAttr, bool topBottomQuery, boo
   if (pQueryAttr && (!stable)) {
     for (int16_t i = 0; i < pQueryAttr->numOfOutput; ++i) {
       if (pQueryAttr->pExpr1[i].base.functionId == TSDB_FUNC_TOP || pQueryAttr->pExpr1[i].base.functionId == TSDB_FUNC_BOTTOM) {
-        return pQueryAttr->pExpr1[i].base.param[0].i64;
+        return (int32_t)pQueryAttr->pExpr1[i].base.param[0].i64;
       }
     }
   }