diff --git a/source/dnode/mnode/impl/inc/mndStream.h b/source/dnode/mnode/impl/inc/mndStream.h
index ebc2e50065..c9155f536c 100644
--- a/source/dnode/mnode/impl/inc/mndStream.h
+++ b/source/dnode/mnode/impl/inc/mndStream.h
@@ -133,7 +133,7 @@ int32_t  mndStreamSetUpdateEpsetAction(SMnode *pMnode, SStreamObj *pStream, SVgr
 
 int32_t mndGetStreamObj(SMnode *pMnode, int64_t streamId, SStreamObj** pStream);
 bool    mndStreamNodeIsUpdated(SMnode *pMnode);
-bool    mndCheckForSnode(SMnode *pMnode, SDbObj *pSrcDb);
+int32_t mndCheckForSnode(SMnode *pMnode, SDbObj *pSrcDb);
 
 int32_t extractNodeEpset(SMnode *pMnode, SEpSet *pEpSet, bool *hasEpset, int32_t taskId, int32_t nodeId);
 int32_t mndProcessStreamHb(SRpcMsg *pReq);
diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index d486570300..9c22543265 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -813,10 +813,9 @@ static int32_t mndProcessCreateStreamReq(SRpcMsg *pReq) {
     goto _OVER;
   }
 
-  bool snodeCheckSucc = mndCheckForSnode(pMnode, pSourceDb);
+  code = mndCheckForSnode(pMnode, pSourceDb);
   mndReleaseDb(pMnode, pSourceDb);
-  if (!snodeCheckSucc) {
-    code = TSDB_CODE_SNODE_NOT_DEPLOYED;
+  if (code != 0) {
     goto _OVER;
   }
 
diff --git a/source/dnode/mnode/impl/src/mndStreamUtil.c b/source/dnode/mnode/impl/src/mndStreamUtil.c
index 206422b795..423d9df4b6 100644
--- a/source/dnode/mnode/impl/src/mndStreamUtil.c
+++ b/source/dnode/mnode/impl/src/mndStreamUtil.c
@@ -1497,13 +1497,13 @@ bool mndStreamNodeIsUpdated(SMnode *pMnode) {
   return updated;
 }
 
-bool mndCheckForSnode(SMnode *pMnode, SDbObj *pSrcDb) {
+int32_t mndCheckForSnode(SMnode *pMnode, SDbObj *pSrcDb) {
   SSdb      *pSdb = pMnode->pSdb;
   void      *pIter = NULL;
   SSnodeObj *pObj = NULL;
 
   if (pSrcDb->cfg.replications == 1) {
-    return true;
+    return TSDB_CODE_SUCCESS;
   } else {
     while (1) {
       pIter = sdbFetch(pSdb, SDB_SNODE, pIter, (void **)&pObj);
@@ -1513,11 +1513,11 @@ bool mndCheckForSnode(SMnode *pMnode, SDbObj *pSrcDb) {
 
       sdbRelease(pSdb, pObj);
       sdbCancelFetch(pSdb, pIter);
-      return true;
+      return TSDB_CODE_SUCCESS;
     }
 
     mError("snode not existed when trying to create stream in db with multiple replica");
-    return false;
+    return TSDB_CODE_SNODE_NOT_DEPLOYED;
   }
 }