change test case
This commit is contained in:
parent
9dfb9e0331
commit
edf238354a
|
@ -381,7 +381,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(5)
|
|
||||||
self.expectSplitError("streamdb")
|
self.expectSplitError("streamdb")
|
||||||
tdSql.execute("drop stream ma;")
|
tdSql.execute("drop stream ma;")
|
||||||
self.expectSplitOk("streamdb")
|
self.expectSplitOk("streamdb")
|
||||||
|
@ -392,7 +391,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(5)
|
|
||||||
|
|
||||||
#self.expectSplitError("topicdb")
|
#self.expectSplitError("topicdb")
|
||||||
tdSql.execute("drop topic toa;")
|
tdSql.execute("drop topic toa;")
|
||||||
|
|
Loading…
Reference in New Issue