diff --git a/src/client/src/tscStream.c b/src/client/src/tscStream.c
index 528e646ff02c4c9507d8a771f176de90bb8bc56d..c8d09412a473703b9bd2c85b13dfedaa3237b2cd 100644
--- a/src/client/src/tscStream.c
+++ b/src/client/src/tscStream.c
@@ -972,7 +972,7 @@ void splitStreamSql(const char *str, char **sql, char **to, char **split) {
     return ;
   }
   // SQL value
-  int32_t len = p1 - str - LABEL_SQL_LEN;
+  int32_t len = (int32_t)(p1 - str - LABEL_SQL_LEN);
   *sql = (char *)tmalloc(len + 1);
   strncpy(*sql, str + LABEL_SQL_LEN, len);
   (*sql)[len] = 0;  // str end 
diff --git a/tests/pytest/stream/sys.py b/tests/pytest/stream/sys.py
index c9a3fccfe68b61da722dcdb2ccab63bf3d5bcabc..fc97934d3fda9d18fa3e745ed3fe6bab3f3d5437 100644
--- a/tests/pytest/stream/sys.py
+++ b/tests/pytest/stream/sys.py
@@ -47,7 +47,7 @@ class TDTestCase:
             "select * from iostrm",
         ]
         for sql in sqls:
-            (rows, _) = tdSql.waitedQuery(sql, 1, 240)
+            (rows, _) = tdSql.waitedQuery(sql, 1, 600)
             if rows < 1:
                 tdLog.exit("failed: sql:%s, expect at least one row" % sql)