diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index da9497dda564c9d1b81c5dce5940dccf64ed1f87..88dcfc2bb31315d0085b3027e93ea94f7f042d06 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -615,9 +615,9 @@ void taos_close_stream(TAOS_STREAM *handle) {
     tscDebug("%p stream:%p is closed", pSql, pStream);
     // notify CQ to release the pStream object
     pStream->fp(pStream->param, NULL, NULL);
-    taos_free_result(pSql);
-
     pStream->pSql = NULL;
+
+    taos_free_result(pSql);
     taosTFree(pStream);
   }
 }
diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index f9bb18081017795d05f0f452b0a4c8bce3d02ece..a6304c5ef3bec2d453ffaeff5e4bd1f16664eeae 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -1383,7 +1383,7 @@ static void doCleanupSubqueries(SSqlObj *pSql, int32_t numOfSubs, SSubqueryState
     taosTFree(pSupport->localBuffer);
     taosTFree(pSupport);
     
-    tscFreeSqlObj(pSub);
+    taos_free_result(pSub);
   }
   
   free(pState);