diff --git a/src/query/src/queryMain.c b/src/query/src/queryMain.c
index a7b40ab0f27b811e3203985748e28a43794816c9..28c5df32516ae83fbccecd40208b2735e484a6c4 100644
--- a/src/query/src/queryMain.c
+++ b/src/query/src/queryMain.c
@@ -346,6 +346,9 @@ int32_t qDumpRetrieveResult(qinfo_t qinfo, SRetrieveTableRsp **pRsp, int32_t *co
     setQueryStatus(pRuntimeEnv, QUERY_OVER);
   }
 
+  RESET_NUM_OF_RESULTS(&(pQInfo->runtimeEnv));
+  pQInfo->lastRetrieveTs = taosGetTimestampMs();
+
   pQInfo->rspContext = NULL;
   pQInfo->dataReady  = QUERY_RESULT_NOT_READY;