diff --git a/tests/pytest/stream/stream2.py b/tests/pytest/stream/stream2.py
index 44882f59721c4967ebb3fea12e356bb7e95d71ae..d71742048a45774fbe6909093840f265b829eb4c 100644
--- a/tests/pytest/stream/stream2.py
+++ b/tests/pytest/stream/stream2.py
@@ -87,6 +87,10 @@ class TDTestCase:
             tdSql.checkData(0, 3, rowNum)
         except Exception as e:
             tdLog.info(repr(e))
+        
+        tdSql.query("show streams")
+        tdSql.checkRows(1)
+        tdSql.checkData(0, 2, 's0')
 
         tdLog.info("===== step8 =====")
         tdSql.query(
@@ -142,6 +146,12 @@ class TDTestCase:
         except Exception as e:
             tdLog.info(repr(e))
 
+        tdSql.query("show streams")
+        tdSql.checkRows(2)
+        tdSql.checkData(0, 2, 's1')
+        tdSql.checkData(1, 2, 's0')
+        
+
     def stop(self):
         tdSql.close()
         tdLog.success("%s successfully executed" % __file__)