change test case

This commit is contained in:
yihaoDeng 2023-10-09 17:05:37 +08:00
parent e78d06c02d
commit a946ee9426
2 changed files with 8 additions and 3 deletions

View File

@ -381,7 +381,8 @@ class TDTestCase:
tdSql.execute("use streamdb;") tdSql.execute("use streamdb;")
tdSql.execute("create table ta(ts timestamp, age int);") tdSql.execute("create table ta(ts timestamp, age int);")
tdSql.execute("create stream ma into sta as select count(*) from ta interval(1s);") tdSql.execute("create stream ma into sta as select count(*) from ta interval(1s);")
#self.expectSplitError("streamdb") time.sleep(3)
self.expectSplitError("streamdb")
tdSql.execute("drop stream ma;") tdSql.execute("drop stream ma;")
self.expectSplitOk("streamdb") self.expectSplitOk("streamdb")
@ -391,7 +392,9 @@ class TDTestCase:
tdSql.execute("use topicdb;") tdSql.execute("use topicdb;")
tdSql.execute("create table ta(ts timestamp, age int);") tdSql.execute("create table ta(ts timestamp, age int);")
tdSql.execute("create topic toa as select * from ta;") tdSql.execute("create topic toa as select * from ta;")
#self.expectSplitError("topicdb") sleep.time(3)
self.expectSplitError("topicdb")
tdSql.execute("drop topic toa;") tdSql.execute("drop topic toa;")
self.expectSplitOk("topicdb") self.expectSplitOk("topicdb")

View File

@ -380,6 +380,7 @@ class TDTestCase:
tdSql.execute("use streamdb;") tdSql.execute("use streamdb;")
tdSql.execute("create table ta(ts timestamp, age int);") tdSql.execute("create table ta(ts timestamp, age int);")
tdSql.execute("create stream ma into sta as select count(*) from ta interval(1s);") tdSql.execute("create stream ma into sta as select count(*) from ta interval(1s);")
time.sleep(3)
self.expectSplitError("streamdb") self.expectSplitError("streamdb")
tdSql.execute("drop stream ma;") tdSql.execute("drop stream ma;")
self.expectSplitOk("streamdb") self.expectSplitOk("streamdb")
@ -390,7 +391,8 @@ class TDTestCase:
tdSql.execute("use topicdb;") tdSql.execute("use topicdb;")
tdSql.execute("create table ta(ts timestamp, age int);") tdSql.execute("create table ta(ts timestamp, age int);")
tdSql.execute("create topic toa as select * from ta;") tdSql.execute("create topic toa as select * from ta;")
#self.expectSplitError("topicdb") time.sleep(3)
self.expectSplitError("topicdb")
tdSql.execute("drop topic toa;") tdSql.execute("drop topic toa;")
self.expectSplitOk("topicdb") self.expectSplitOk("topicdb")