From 9621a2aab290c666dffb722a7cecd9a8a265b6a9 Mon Sep 17 00:00:00 2001 From: mohan Date: Wed, 5 Jun 2019 16:58:05 +0530 Subject: [PATCH] Add possible fix for the test case failure --- .../siddhi/io/kafka/multidc/KafkaMultiDCSinkTestCases.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/component/src/test/java/org/wso2/extension/siddhi/io/kafka/multidc/KafkaMultiDCSinkTestCases.java b/component/src/test/java/org/wso2/extension/siddhi/io/kafka/multidc/KafkaMultiDCSinkTestCases.java index 4c89478b..1106cd2f 100644 --- a/component/src/test/java/org/wso2/extension/siddhi/io/kafka/multidc/KafkaMultiDCSinkTestCases.java +++ b/component/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"};