fix(query): set the correct rows in data block.

This commit is contained in:
Haojun Liao 2023-02-18 19:46:37 +08:00
parent 06a3c1c9c0
commit 4853522e11
1 changed files with 3 additions and 0 deletions

View File

@ -1075,6 +1075,9 @@ static int32_t mndRetrieveSubscribe(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock
}
#endif
pBlock->info.rows = numOfRows;
taosRUnLockLatch(&pSub->lock);
sdbRelease(pSdb, pSub);
}