diff --git a/src/client/inc/tsclient.h b/src/client/inc/tsclient.h
index 9cfeffb2d80996b99e81413f072e31f165db17c4..6b5c65df85364092c1b9a18a5880beea600a3924 100644
--- a/src/client/inc/tsclient.h
+++ b/src/client/inc/tsclient.h
@@ -371,6 +371,7 @@ typedef struct SSqlObj {
   SSubqueryState   subState;
   struct SSqlObj **pSubs;
 
+  int global;
   struct SSqlObj  *prev, *next;
   int64_t self;
 } SSqlObj;
diff --git a/src/client/src/tscSql.c b/src/client/src/tscSql.c
index 654a41fe7765fff947e5af3d7f4fced855eddfa6..82788eec03ebaf6aa54ba19d8ce13cc237b74397 100644
--- a/src/client/src/tscSql.c
+++ b/src/client/src/tscSql.c
@@ -353,8 +353,10 @@ TAOS_RES* taos_query_c(TAOS *taos, const char *sqlstr, uint32_t sqlLen, TAOS_RES
     terrno = TSDB_CODE_TSC_OUT_OF_MEMORY;
     return NULL;
   }
+  
   tscError("curre query count: %ld",atomic_add_fetch_64(&queryIncr, 1)); 
   tsem_init(&pSql->rspSem, 0, 0);
+  pSql->global = 100; 
   doAsyncQuery(pObj, pSql, waitForQueryRsp, taos, sqlstr, sqlLen);
 
   if (res != NULL) {
@@ -660,7 +662,7 @@ void taos_free_result(TAOS_RES *res) {
     tscError("%p already released sqlObj", res);
     return;
   }
-  if (0 == pSql->subState.numOfSub) {
+  if (100 == pSql->global) {
     tscError("current query count: %ld", atomic_sub_fetch_64(&queryIncr, 1));
   }