diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c
index 18d11c6fa6165d645b26860ae83b31d1d65d300e..e45632cb5ba7c648cdc755baa7b912ac7b0d46e1 100644
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -4887,6 +4887,7 @@ static void tableQueryImpl(SQInfo *pQInfo) {
       }
 
       qDebug("QInfo:%p current:%" PRId64 " returned, total:%" PRId64, pQInfo, pQuery->rec.rows, pQuery->rec.total);
+      return;
     } else {
       pQuery->rec.rows = 0;
       pQInfo->groupIndex = 0;  // always start from 0