diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index da743e1597..652551e34d 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -2229,7 +2229,7 @@ void tscFirstRoundRetrieveCallback(void* param, TAOS_RES* tres, int numOfRows) {
     }
   }
 
-  if (!pRes->completed) {
+  if (!pRes->completed && numOfRows > 0) {
     taos_fetch_rows_a(tres, tscFirstRoundRetrieveCallback, param);
     return;
   }