Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

wait more than the group by time

pull/535/head
John Shahid 2014-05-13 13:30:30 -04:00
parent a90a0b8a0e
commit a1702044f7
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/integration/multiple_servers_test.go
View File

@ -808,7 +808,7 @@ func (self *ServerSuite) TestContinuousQuerySequenceNumberAssignmentWithInterpol
self.serverProcesses[0].QueryAsRoot("test_cq", "select count(c1) from points group by time(5s), c2 into :series_name.count.[c2];", false, c)
self.serverProcesses[0].AssertContinuousQueryCount("test_cq", 1, c)
self.serverProcesses[0].WaitForServerToSync()
time.Sleep(time.Second)
time.Sleep(6 * time.Second)
self.serverProcesses[0].QueryAsRoot("test_cq", "drop continuous query 1;", false, c)
@ -830,7 +830,7 @@ func (self *ServerSuite) TestContinuousQuerySequenceNumberAssignmentWithInterpol
self.serverProcesses[0].QueryAsRoot("test_cq", "select count(c1) from points group by time(5s), c2 into :series_name.count.[c2];", false, c)
self.serverProcesses[0].AssertContinuousQueryCount("test_cq", 1, c)
self.serverProcesses[0].WaitForServerToSync()
time.Sleep(time.Second)
time.Sleep(6 * time.Second)
collection := self.serverProcesses[0].Query("test_cq", "select * from points;", false, c)
series := collection.GetSeries("points", c)