From 74862378e73e17ec0602d78096d2b374cfb3ebac Mon Sep 17 00:00:00 2001 From: Anmol Vijaywargiya Date: Tue, 10 Aug 2021 12:31:22 +0530 Subject: [PATCH] Increase sleep before closing stream as well as the join window ms --- test/ziggurat/streams_test.clj | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/test/ziggurat/streams_test.clj b/test/ziggurat/streams_test.clj index 47ce9ca0..af0da310 100644 --- a/test/ziggurat/streams_test.clj +++ b/test/ziggurat/streams_test.clj @@ -294,7 +294,7 @@ (-> (ziggurat-config) (assoc-in [:stream-router :default :consumer-type] :stream-joins) (assoc-in [:stream-router :default :input-topics] {:topic {:name "topic"} :another-test-topic {:name "another-test-topic"}}) - (assoc-in [:stream-router :default :join-cfg] {:topic-and-another-test-topic {:join-window-ms 5000 :join-type :outer}}) + (assoc-in [:stream-router :default :join-cfg] {:topic-and-another-test-topic {:join-window-ms 6000 :join-type :outer}}) (assoc-in [:stream-router :default :application-id] (rand-application-id)) (assoc-in [:stream-router :default :changelog-topic-replication-factor] changelog-topic-replication-factor)))] (Thread/sleep 10000) ;;waiting for streams to start @@ -306,7 +306,7 @@ kvs (props) (MockTime.)) - (Thread/sleep 5000) ;;wating for streams to consume messages + (Thread/sleep 10000) ;;wating for streams to consume messages (stop-streams streams) (is (= times @message-received-count)))))))