diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index 73fdb02855e0bb0561630f87a2322385839698b1..2fa885ba7760a01e88eaecc114e1aced4cb11ea6 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -211,6 +211,7 @@ static void tscProcessStreamQueryCallback(void *param, TAOS_RES *tres, int numOf
     tfree(pSql->pSubs);
     pSql->subState.numOfSub = 0;
 
+    pSql->parseRetry = 0;
     int32_t code = tsParseSql(pSql, true);
     if (code == TSDB_CODE_SUCCESS) {
       cbParseSql(pStream, pSql, code);
@@ -220,6 +221,7 @@ static void tscProcessStreamQueryCallback(void *param, TAOS_RES *tres, int numOf
       tscError("0x%"PRIx64" open stream failed, code:%s", pSql->self, tstrerror(code));
       taosReleaseRef(tscObjRef, pSql->self);
       free(pStream);
+      return;
     }
 
 //    tscSetRetryTimer(pStream, pStream->pSql, retryDelay);