diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index 25f51b85df..57f3ac174c 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -792,7 +792,7 @@ static int32_t checkForNumOfStreams(SMnode *pMnode, SStreamObj *pStreamObj) {  /
     if (pStream->targetStbUid == pStreamObj->targetStbUid) {
       mError("Cannot write the same stable as other stream:%s", pStream->name);
       sdbCancelFetch(pMnode->pSdb, pIter);
-      terrno = TSDB_CODE_MND_TOO_MANY_STREAMS;
+      terrno = TSDB_CODE_MND_INVALID_TARGET_TABLE;
       return terrno;
     }
   }
diff --git a/tests/system-test/8-stream/max_delay_session.py b/tests/system-test/8-stream/max_delay_session.py
index 46c4c5801d..7e9d365fc8 100644
--- a/tests/system-test/8-stream/max_delay_session.py
+++ b/tests/system-test/8-stream/max_delay_session.py
@@ -27,6 +27,8 @@ class TDTestCase:
         self.tb_stream_des_table = f'{self.tb_name}{self.tdCom.des_table_suffix}'
         self.tdCom.date_time = self.tdCom.dataDict["start_ts"]
 
+        time.sleep(1)
+
         if watermark is not None:
             watermark_value = f'{self.tdCom.dataDict["watermark"]}s'
         else: