diff --git a/tests/system-test/8-stream/checkpoint_info.py b/tests/system-test/8-stream/checkpoint_info.py index 522017a702..83b5ba89d6 100644 --- a/tests/system-test/8-stream/checkpoint_info.py +++ b/tests/system-test/8-stream/checkpoint_info.py @@ -86,7 +86,7 @@ class TDTestCase: tdLog.debug("========restart stream========") time.sleep(10) for i in range(5): - tdSql.execute("pause stream s1") + tdSql.execute("pause stream s1", 60) time.sleep(2) tdSql.execute("resume stream s1") def initstream(self): @@ -125,11 +125,12 @@ class TDTestCase: print("========run========") self.initstream() self.restart_stream() - time.sleep(60) + time.sleep(5) self.print_time_info() self.redistribute_vnode() + time.sleep(20) self.restart_stream() - time.sleep(60) + time.sleep(5) self.print_time_info() def stop(self):