diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c index 425270b36a7734bc0817b1b9e5fd8cbf6fc10725..340a4c096025799a05812691665a2084d992b53e 100644 --- a/src/query/src/qExecutor.c +++ b/src/query/src/qExecutor.c @@ -6997,7 +6997,7 @@ SOperatorInfo* createSLimitOperatorInfo(SQueryRuntimeEnv* pRuntimeEnv, SOperator pInfo->slimit = pQueryAttr->slimit; pInfo->limit = pQueryAttr->limit; pInfo->capacity = pRuntimeEnv->resultInfo.capacity; - pInfo->threshold = pInfo->capacity * 0.8; + pInfo->threshold = (int64_t) (pInfo->capacity * 0.8); pInfo->currentOffset = pQueryAttr->limit.offset; pInfo->currentGroupOffset = pQueryAttr->slimit.offset; pInfo->multigroupResult= multigroupResult;