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

59c72beb · Haojun Liao · 4853522e · 59c72beb
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/dnode/mnode/impl/src/mndSubscribe.c source/dnode/mnode/impl/src/mndSubscribe.c +3 -1

未找到文件。
--- a/source/dnode/mnode/impl/src/mndSubscribe.c
+++ b/source/dnode/mnode/impl/src/mndSubscribe.c
@@ -966,7 +966,9 @@ static int32_t mndRetrieveSubscribe(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock

  while (numOfRows < rowsCapacity) {
    pShow->pIter = sdbFetch(pSdb, SDB_SUBSCRIBE, pShow->pIter, (void **)&pSub);
-    if (pShow->pIter == NULL) break;
+    if (pShow->pIter == NULL) {
+      break;
+    }

    taosRLockLatch(&pSub->lock);