From a576be6ae51d75b0a9cefb1cd7e647cc7965608f Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 15 Mar 2024 15:19:20 +0800 Subject: [PATCH] fix(stream): set the correct rows info for stream tasks when retreiving task info. --- source/dnode/mnode/impl/src/mndStream.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 6aab2424f7..f20b118155 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -1508,6 +1508,8 @@ static int32_t mndRetrieveStreamTask(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock } } + pBlock->info.rows = numOfRows; + destroyStreamTaskIter(pIter); taosRUnLockLatch(&pStream->lock);