From 4853522e1186af1b30a7593d27387227f9bf007f Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 18 Feb 2023 19:46:37 +0800 Subject: [PATCH] fix(query): set the correct rows in data block. --- source/dnode/mnode/impl/src/mndSubscribe.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/source/dnode/mnode/impl/src/mndSubscribe.c b/source/dnode/mnode/impl/src/mndSubscribe.c index 153bb8bd04..ea1e16ef8b 100644 --- a/source/dnode/mnode/impl/src/mndSubscribe.c +++ b/source/dnode/mnode/impl/src/mndSubscribe.c @@ -1075,6 +1075,9 @@ static int32_t mndRetrieveSubscribe(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock } #endif + + pBlock->info.rows = numOfRows; + taosRUnLockLatch(&pSub->lock); sdbRelease(pSdb, pSub); } -- GitLab