Merge pull request #99 from mohanvive/master

Add possible fix for the test case failure
siddhi-io · Jun 5, 2019 · 03b7971 · 03b7971
2 parents c124a18 + 9621a2a
commit 03b7971
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...t/src/test/java/org/wso2/extension/siddhi/io/kafka/multidc/KafkaMultiDCSinkTestCases.java b/...t/src/test/java/org/wso2/extension/siddhi/io/kafka/multidc/KafkaMultiDCSinkTestCases.java
@@ -162,7 +162,7 @@ public synchronized void receive(Event[] events) {
         fooStream.send(new Object[]{"WSO2", 55.6f, 100L});
         fooStream.send(new Object[]{"WSO2", 75.6f, 102L});
         fooStream.send(new Object[]{"WSO2", 57.6f, 103L});
-        Thread.sleep(4000);
+        Thread.sleep(6000);
 
         Assert.assertTrue(count == 6);
         sourceOneApp.shutdown();
@@ -176,7 +176,7 @@ public synchronized void receive(Event[] events) {
     Even if one of the brokers are failing publishing should not be stopped for the other broker. Therefore, one
     siddhi app must receive events.
      */
-//    @Test (dependsOnMethods = "testMultiDCSinkWithBothBrokersRunning")
+    @Test (dependsOnMethods = "testMultiDCSinkWithBothBrokersRunning")
     public void testMultiDCSinkWithOneBrokersFailing() throws InterruptedException {
         LOG.info("Creating test for publishing events for static topic without a partition");
         String topics[] = new String[]{"myTopic"};