diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index 93a865a78b07d4152148c3fe236f16f09ad3fb42..3c8ba00e827f149f923e7889e0ef53885941f173 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -620,10 +620,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);
 
-    tscFreeSqlObj(pSql);
     pStream->pSql = NULL;
-
     taosTFree(pStream);
   }
 }