Reduce the probability of test failure

siddhi-io · Sep 10, 2019 · 4cd22c7 · 4cd22c7
1 parent a24d854
commit 4cd22c7
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/...-core/src/test/java/io/siddhi/core/query/pattern/absent/LogicalAbsentPatternTestCase.java b/...-core/src/test/java/io/siddhi/core/query/pattern/absent/LogicalAbsentPatternTestCase.java
@@ -1937,9 +1937,9 @@ public void testQueryAbsent47() throws InterruptedException {
         InputHandler stream3 = siddhiAppRuntime.getInputHandler("Stream3");
         siddhiAppRuntime.start();
 
-        Thread.sleep(2200);
+        Thread.sleep(2100);
         stream3.send(new Object[]{"WSO2", 35.0f, 100});
-        Thread.sleep(2200);
+        Thread.sleep(2100);
         stream3.send(new Object[]{"IBM", 55.0f, 100});
         Thread.sleep(1000);
 
@@ -1952,9 +1952,9 @@ public void testQueryAbsent47() throws InterruptedException {
         siddhiAppRuntime.shutdown();
     }
 
-    @Test(dependsOnMethods = {"testQueryAbsent47"})
+    @Test //(dependsOnMethods = {"testQueryAbsent47"})
     public void testQueryAbsent48() throws InterruptedException {
-        log.info("Test the query every (not e1 for 1 sec or not e2 for 1 sec) -> e3 with only e3 after 2 seconds");
+        log.info("Test the query every (not e1 for 2 sec or not e2 for 2 sec) -> e3 with only e3 after 4 seconds");
 
         SiddhiManager siddhiManager = new SiddhiManager();
 
@@ -1964,7 +1964,7 @@ public void testQueryAbsent48() throws InterruptedException {
                 "define stream Stream3 (symbol string, price float, volume int); ";
         String query = "" +
                 "@info(name = 'query1') " +
-                "from every (not Stream1[price>10] for 1 sec or not Stream2[price>20] for 1 sec) -> " +
+                "from every (not Stream1[price>10] for 2 sec or not Stream2[price>20] for 2 sec) -> " +
                 "e3=Stream3[price>30] " +
                 "select e3.symbol as symbol " +
                 "insert into OutputStream ;";
@@ -1977,7 +1977,7 @@ public void testQueryAbsent48() throws InterruptedException {
         InputHandler stream3 = siddhiAppRuntime.getInputHandler("Stream3");
         siddhiAppRuntime.start();
 
-        Thread.sleep(2100);
+        Thread.sleep(4200);
         stream3.send(new Object[]{"WSO2", 35.0f, 100});
         Thread.sleep(1000);