diff --git a/src/integration/benchmark_test.go b/src/integration/benchmark_test.go index e9f58c857c0..200f7c19fa4 100644 --- a/src/integration/benchmark_test.go +++ b/src/integration/benchmark_test.go @@ -1419,6 +1419,7 @@ func (self *IntegrationSuite) TestLargeDeletes(c *C) { } ]`, string(pointsString))) c.Assert(err, IsNil) + time.Sleep(5 * time.Second) bs, err := self.server.RunQuery("select count(val1) from test_large_deletes", "m") c.Assert(err, IsNil) data := []*SerializedSeries{} @@ -1431,6 +1432,8 @@ func (self *IntegrationSuite) TestLargeDeletes(c *C) { _, err = self.server.RunQuery(query, "m") c.Assert(err, IsNil) + time.Sleep(5 * time.Second) + // this shouldn't return any data bs, err = self.server.RunQuery("select count(val1) from test_large_deletes", "m") c.Assert(err, IsNil)