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