changes sleep duration and join-window for join tests

Author: shubhang.balkundi

test/ziggurat/streams_test.clj

@@ -234,7 +234,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 :inner}})
+                                                        (assoc-in [:stream-router :default :join-cfg] {:topic-and-another-test-topic {:join-window-ms 6000 :join-type :inner}})
                                                         (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
@@ -246,7 +246,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)))))))
 
@@ -264,7 +264,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 :left}})
+                                                        (assoc-in [:stream-router :default :join-cfg] {:topic-and-another-test-topic {:join-window-ms 6000 :join-type :left}})
                                                         (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
@@ -276,7 +276,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)))))))