From af1534b4f7ba787b2d81beb78089de1526bd9b0f Mon Sep 17 00:00:00 2001 From: Eno Thereska Date: Mon, 8 May 2017 17:30:18 +0100 Subject: [PATCH] Adjust timeout in low resource environments --- .../integration/QueryableStateIntegrationTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java index b435ceb41174f..ab23af0316c78 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java @@ -287,7 +287,7 @@ public boolean conditionMet() { } } - }, 30000, "waiting for metadata, store and value to be non null"); + }, 120000, "waiting for metadata, store and value to be non null"); } } @@ -319,7 +319,7 @@ public boolean conditionMet() { } } - }, 30000, "waiting for metadata, store and value to be non null"); + }, 120000, "waiting for metadata, store and value to be non null"); } } @@ -850,7 +850,7 @@ private void waitUntilAtLeastNumRecordProcessed(final String topic, final int nu config, topic, numRecs, - 60 * 1000); + 120 * 1000); } private Set> fetch(final ReadOnlyWindowStore store, @@ -909,7 +909,7 @@ public void run() { final Properties producerConfig = new Properties(); producerConfig.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, CLUSTER.bootstrapServers()); producerConfig.put(ProducerConfig.ACKS_CONFIG, "all"); - producerConfig.put(ProducerConfig.RETRIES_CONFIG, 0); + producerConfig.put(ProducerConfig.RETRIES_CONFIG, 10); producerConfig.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class); producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);