From 7d667e9443587473e76a43bc57a854c19c00e55e Mon Sep 17 00:00:00 2001 From: wpan Date: Thu, 2 Sep 2021 08:36:14 +0800 Subject: [PATCH] add debug info --- src/client/src/tscServer.c | 2 +- src/client/src/tscSubquery.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c index 8fa26f56c9..a80839f1a2 100644 --- a/src/client/src/tscServer.c +++ b/src/client/src/tscServer.c @@ -2772,7 +2772,7 @@ int tscProcessQueryRsp(SSqlObj *pSql) { pRes->data = NULL; tscResetForNextRetrieve(pRes); - pSql->rspReceived = 1; + 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 4acf173c9b..f1c4bb29f3 100644 --- a/src/client/src/tscSubquery.c +++ b/src/client/src/tscSubquery.c @@ -1716,7 +1716,7 @@ void tscFetchDatablockForSubquery(SSqlObj* pSql) { STableMetaInfo* pTableMetaInfo = tscGetMetaInfo(pQueryInfo, 0); if (pRes1->row >= pRes1->numOfRows) { - assert(pSql1->rspReceived == 1); + 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); -- GitLab