fix: show stream

f8be9820 · Liu Jicong · 3ae3fd65 · f8be9820
隐藏空白更改
内联并排

Showing with 6 addition and 1 deletion

source/dnode/mnode/impl/src/mndStream.c source/dnode/mnode/impl/src/mndStream.c +6 -1

未找到文件。
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -471,8 +471,13 @@ static int32_t mndRetrieveStream(SNodeMsg *pReq, SShowObj *pShow, SSDataBlock *p

    pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
    colDataAppend(pColInfo, numOfRows, (const char *)&pStream->trigger, false);
+
+    numOfRows++;
+    sdbRelease(pSdb, pStream);
  }
-  return 0;
+
+  pShow->numOfRows += numOfRows;
+  return numOfRows;
 }

 static void mndCancelGetNextStream(SMnode *pMnode, void *pIter) {