diff --git a/server/src/test/java/io/druid/client/CachePopulatingQueryRunnerTest.java b/server/src/test/java/io/druid/client/CachePopulatingQueryRunnerTest.java index b87cb15b317..bb73c5d58bc 100644 --- a/server/src/test/java/io/druid/client/CachePopulatingQueryRunnerTest.java +++ b/server/src/test/java/io/druid/client/CachePopulatingQueryRunnerTest.java @@ -123,7 +123,7 @@ public class CachePopulatingQueryRunnerTest Sequence res = runner.run(builder.build()); // base sequence is not closed yet - Assert.assertTrue(closable.isClosed()); + Assert.assertFalse("sequence must not be closed", closable.isClosed()); ArrayList results = Sequences.toList(res, new ArrayList()); Assert.assertTrue(closable.isClosed()); Assert.assertEquals(expectedRes, results);