From 4cd22c76ef723a4008bed4cbc762932a52c56968 Mon Sep 17 00:00:00 2001
From: Mohan <mohan.vive@gmail.com>
Date: Tue, 10 Sep 2019 16:23:38 +0530
Subject: [PATCH] Reduce the probability of test failure

---
 .../pattern/absent/LogicalAbsentPatternTestCase.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/modules/siddhi-core/src/test/java/io/siddhi/core/query/pattern/absent/LogicalAbsentPatternTestCase.java b/modules/siddhi-core/src/test/java/io/siddhi/core/query/pattern/absent/LogicalAbsentPatternTestCase.java
index bda790bda0..04359f665d 100644
--- a/modules/siddhi-core/src/test/java/io/siddhi/core/query/pattern/absent/LogicalAbsentPatternTestCase.java
+++ b/modules/siddhi-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);