From 869c08132c8122136ae82ae9c0a47ea962f9e816 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 22 Jul 2024 15:53:10 +0800 Subject: [PATCH] fix(stream): fix exist check. --- source/dnode/mnode/impl/src/mndSma.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/mnode/impl/src/mndSma.c b/source/dnode/mnode/impl/src/mndSma.c index 272897eadf..0523417f25 100644 --- a/source/dnode/mnode/impl/src/mndSma.c +++ b/source/dnode/mnode/impl/src/mndSma.c @@ -769,7 +769,7 @@ static int32_t mndProcessCreateSmaReq(SRpcMsg *pReq) { mndGetStreamNameFromSmaName(streamName, createReq.name); code = mndAcquireStream(pMnode, streamName, &pStream); - if (pStream != NULL || code != 0) { + if (pStream != NULL || code == 0) { mError("sma:%s, failed to create since stream:%s already exist", createReq.name, streamName); terrno = TSDB_CODE_MND_STREAM_ALREADY_EXIST; goto _OVER;