diff --git a/src/client/inc/tsclient.h b/src/client/inc/tsclient.h
index b6d46ecbcdc088f63fc08e69306bae6e56886696..b9aaea8469795771854919a2584d28d5c3f4e9e3 100644
--- a/src/client/inc/tsclient.h
+++ b/src/client/inc/tsclient.h
@@ -391,7 +391,6 @@ typedef struct SSqlObj {
   int32_t          retryReason;  // previous error code
   struct SSqlObj  *prev, *next;
   int64_t          self;
-  int32_t          rspReceived;
 } SSqlObj;
 
 typedef struct SSqlStream {
diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index e087c17d9d1c84341d0f067944e5ee7e640da9b0..0239805e9c7de7d8ffb2ad3b6175792fdd6c2acf 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -2773,7 +2773,6 @@ int tscProcessQueryRsp(SSqlObj *pSql) {
   pRes->data = NULL;
 
   tscResetForNextRetrieve(pRes);
-  pSql->rootObj->rspReceived = 1;
   tscDebug("0x%"PRIx64" query rsp received, qId:0x%"PRIx64, pSql->self, pRes->qId);
   return 0;
 }
diff --git a/src/client/src/tscSubquery.c b/src/client/src/tscSubquery.c
index f1c4bb29f36b48f0f3fa9e670e48c89bf7fdbfd8..8e579ad2210920c442a4c447c2fed267b658b546 100644
--- a/src/client/src/tscSubquery.c
+++ b/src/client/src/tscSubquery.c
@@ -1716,7 +1716,6 @@ void tscFetchDatablockForSubquery(SSqlObj* pSql) {
     STableMetaInfo* pTableMetaInfo = tscGetMetaInfo(pQueryInfo, 0);
     
     if (pRes1->row >= pRes1->numOfRows) {
-      assert(pSql1->rootObj->rspReceived == 1);
       tscDebug("0x%"PRIx64" subquery:0x%"PRIx64" retrieve data from vnode, subquery:%d, vgroupIndex:%d", pSql->self, pSql1->self,
                pSupporter->subqueryIndex, pTableMetaInfo->vgroupIndex);