Reduce the probability of test failure

siddhi-io · Sep 10, 2019 · a24d854 · a24d854
1 parent 4ab6cce
commit a24d854
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/modules/siddhi-core/src/test/java/io/siddhi/core/query/window/CronWindowTestCase.java b/modules/siddhi-core/src/test/java/io/siddhi/core/query/window/CronWindowTestCase.java
@@ -23,6 +23,7 @@
 import io.siddhi.core.stream.input.InputHandler;
 import io.siddhi.core.stream.output.StreamCallback;
 import io.siddhi.core.util.EventPrinter;
+import io.siddhi.core.util.SiddhiTestHelper;
 import org.apache.log4j.Logger;
 import org.testng.AssertJUnit;
 import org.testng.annotations.BeforeMethod;
@@ -126,7 +127,7 @@ public void receive(Event[] events) {
         Thread.sleep(7000);
         inputHandler.send(new Object[]{"IBM43", 700f, 0});
         inputHandler.send(new Object[]{"WSO4343", 60.5f, 1});
-        Thread.sleep(7000);
+        SiddhiTestHelper.waitForEvents(7000, 4, removeEventCount, 20000);
         AssertJUnit.assertEquals(4, removeEventCount);
         AssertJUnit.assertTrue(eventArrived);
         siddhiAppRuntime.shutdown();