From 0d131116e72697481de12273a4b1d39392c07a2e Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Tue, 23 Jul 2024 11:32:21 +0800
Subject: [PATCH] fix(stream): check return value.

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

diff --git a/source/dnode/mnode/impl/src/mndStreamTrans.c b/source/dnode/mnode/impl/src/mndStreamTrans.c
index b189ddb3cb..c0a869fb77 100644
--- a/source/dnode/mnode/impl/src/mndStreamTrans.c
+++ b/source/dnode/mnode/impl/src/mndStreamTrans.c
@@ -277,7 +277,7 @@ int32_t doKillCheckpointTrans(SMnode *pMnode, const char *pDBName, size_t len) {
 
     SStreamObj *pStream = NULL;
     int32_t code = mndGetStreamObj(pMnode, pTransInfo->streamId, &pStream);
-    if (pStream != NULL || code != 0) {
+    if (pStream != NULL && code == 0) {
       if (identicalName(pStream->sourceDb, pDBName, len)) {
         mndKillTransImpl(pMnode, pTransInfo->transId, pStream->sourceDb);
       } else if (identicalName(pStream->targetDb, pDBName, len)) {