From 290ff8d0b670059fef83d2a8d7fa99b005e4d3b0 Mon Sep 17 00:00:00 2001
From: dapan1121 <wpan@taosdata.com>
Date: Mon, 11 Oct 2021 10:07:21 +0800
Subject: [PATCH] fix cq crash issue

---
 src/client/src/tscStream.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index 63459a5979..e2e7c7cdb3 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -752,7 +752,7 @@ TAOS_STREAM *taos_open_stream(TAOS *taos, const char *sqlstr, void (*fp)(void *p
 void taos_close_stream(TAOS_STREAM *handle) {
   SSqlStream *pStream = (SSqlStream *)handle;
 
-  SSqlObj *pSql = (SSqlObj *)atomic_exchange_ptr(&pStream->pSql, 0);
+  SSqlObj *pSql = pStream->pSql;
   if (pSql == NULL) {
     return;
   }
-- 
GitLab