xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix bug

This commit is contained in:
dapan1121 2021-04-22 09:50:44 +08:00
parent 23f23a445d
commit 2bfc6a90a5
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/client/src/tscStream.c
View File

@ -403,11 +403,13 @@ static void tscSetNextLaunchTimer(SSqlStream *pStream, SSqlObj *pSql) {
return; return;
} }
if (pStream->stime > 0) {
timer = pStream->stime - taosGetTimestamp(pStream->precision); timer = pStream->stime - taosGetTimestamp(pStream->precision);
if (timer < 0) { if (timer < 0) {
timer = 0; timer = 0;
} }
} }
}
timer += getLaunchTimeDelay(pStream); timer += getLaunchTimeDelay(pStream);

2
tests/pytest/stream/sys.py
View File

@ -47,7 +47,7 @@ class TDTestCase:
"select * from iostrm", "select * from iostrm",
] ]
for sql in sqls: for sql in sqls:
(rows, _) = tdSql.waitedQuery(sql, 1, 120) (rows, _) = tdSql.waitedQuery(sql, 1, 240)
if rows < 1: if rows < 1:
tdLog.exit("failed: sql:%s, expect at least one row" % sql) tdLog.exit("failed: sql:%s, expect at least one row" % sql)