diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c index 3e683609d125e0bd7a7282cf9834c2ab62aa78a6..f47cd347298a96b7f80dced6569bed8355c94de2 100644 --- a/src/query/src/qExecutor.c +++ b/src/query/src/qExecutor.c @@ -5515,6 +5515,7 @@ static void sequentialTableProcess(SQInfo *pQInfo) { // the limitation of output result is reached, set the query completed if (limitResults(pRuntimeEnv)) { + setQueryStatus(pQuery, QUERY_COMPLETED); SET_STABLE_QUERY_OVER(pQInfo); break; }