diff --git a/tests/pytest/stream/new.py b/tests/pytest/stream/new.py
index 70f300e937b2ed422231a774d2bca1183ce6fd0a..4a0e47c01ad9f9aac7ed78be0ff4fc93fc0d41ed 100644
--- a/tests/pytest/stream/new.py
+++ b/tests/pytest/stream/new.py
@@ -42,7 +42,7 @@ class TDTestCase:
 
         tdLog.info("=============== step3")
         start = time.time()
-        tdSql.waitedQuery("select * from st", 1, 120)
+        tdSql.waitedQuery("select * from st", 1, 180)
         delay = int(time.time() - start) + 80
         v = tdSql.getData(0, 3)
         if v >= 51:
diff --git a/tests/pytest/util/sql.py b/tests/pytest/util/sql.py
index 16931cca333a3300b7d0d6831bbb51db0238b1d1..9d1d3a570394f2a757da2a16d4aee8648e4c0163 100644
--- a/tests/pytest/util/sql.py
+++ b/tests/pytest/util/sql.py
@@ -87,6 +87,7 @@ class TDSql:
                 self.queryResult = self.cursor.fetchall()
                 self.queryRows = len(self.queryResult)
                 self.queryCols = len(self.cursor.description)
+                tdLog.info("sql: %s, try to retrieve %d rows,get %d rows" % (sql, expectRows, self.queryRows))
                 if self.queryRows >= expectRows:
                     return (self.queryRows, i)
                 time.sleep(1)