diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 43a22e0637..7b410501ca 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -539,9 +539,11 @@ void streamMetaClear(SStreamMeta* pMeta) {
     streamMetaReleaseTask(pMeta, p);
   }
 
-  int32_t code = taosRemoveRef(streamBackendId, pMeta->streamBackendRid);
-  if (code) {
-    stError("vgId:%d remove stream backend Ref failed, rid:%"PRId64, pMeta->vgId, pMeta->streamBackendRid);
+  if (pMeta->streamBackendRid != 0) {
+    int32_t code = taosRemoveRef(streamBackendId, pMeta->streamBackendRid);
+    if (code) {
+      stError("vgId:%d remove stream backend Ref failed, rid:%" PRId64, pMeta->vgId, pMeta->streamBackendRid);
+    }
   }
 
   taosHashClear(pMeta->pTasksMap);
diff --git a/tests/system-test/0-others/backquote_check.py b/tests/system-test/0-others/backquote_check.py
index b35701f1df..2858373ced 100644
--- a/tests/system-test/0-others/backquote_check.py
+++ b/tests/system-test/0-others/backquote_check.py
@@ -67,11 +67,15 @@ class TDTestCase:
         tdSql.execute(f'use {self.dbname}')
         tdSql.execute(f'create stable {self.stbname} (ts timestamp,c0 int) tags(t0 int)')
         tdSql.execute(f'create stream `{self.streamname}` into `{self.streamtb}` as select count(*) from {self.stbname} interval(10s);')
+
+        time.sleep(15)
         tdSql.query('show streams')
         tdSql.checkEqual(tdSql.queryResult[0][0],self.streamname)
         tdSql.execute(f'drop stream {self.streamname}')
         tdSql.execute(f'drop stable {self.streamtb}')
         tdSql.execute(f'create stream {self.streamname} into `{self.streamtb}` as select count(*) from {self.stbname} interval(10s);')
+
+        time.sleep(10)
         tdSql.query('show streams')
         tdSql.checkEqual(tdSql.queryResult[0][0],self.streamname)
         tdSql.execute(f'drop stream `{self.streamname}`')