change test case
This commit is contained in:
parent
8fa631cb62
commit
9dfb9e0331
|
@ -380,7 +380,6 @@ 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")
|
||||||
|
@ -391,7 +390,6 @@ 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;")
|
||||||
time.sleep(3)
|
|
||||||
#self.expectSplitError("topicdb")
|
#self.expectSplitError("topicdb")
|
||||||
tdSql.execute("drop topic toa;")
|
tdSql.execute("drop topic toa;")
|
||||||
self.expectSplitOk("topicdb")
|
self.expectSplitOk("topicdb")
|
||||||
|
|
Loading…
Reference in New Issue