From 5f9f6310a430cc588c68a71b696486c90ec06da4 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Tue, 23 Jul 2024 09:57:13 +0800
Subject: [PATCH] fix(stream): check the correct return value.

---
 source/dnode/mnode/impl/src/mndStream.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index 6362fbaa79..df8800aee4 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -1289,7 +1289,7 @@ static int32_t mndProcessStreamCheckpoint(SRpcMsg *pReq) {
 
     SStreamObj *p = NULL;
     code = mndGetStreamObj(pMnode, pCheckpointInfo->streamId, &p);
-    if (p != NULL || code != 0) {
+    if (p != NULL && code == 0) {
       code = mndProcessStreamCheckpointTrans(pMnode, p, checkpointId, 1, true);
       sdbRelease(pSdb, p);