Repository: kafka Updated Branches: refs/heads/trunk 78ace3725 -> 5b36adde4
KAFKA-4222: Adjust timeout in low resource environments Author: Eno Thereska <[email protected]> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2996 from enothereska/KAFKA-4222-queryOnRebalance Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5b36adde Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5b36adde Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5b36adde Branch: refs/heads/trunk Commit: 5b36adde4f158d9d3b47bb98123a0bcca8028288 Parents: 78ace37 Author: Eno Thereska <[email protected]> Authored: Tue May 9 09:23:35 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Tue May 9 09:23:35 2017 -0700 ---------------------------------------------------------------------- .../streams/integration/QueryableStateIntegrationTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/5b36adde/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java ---------------------------------------------------------------------- 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 b435ceb..ab23af0 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 class QueryableStateIntegrationTest { } } - }, 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 class QueryableStateIntegrationTest { } } - }, 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 @@ public class QueryableStateIntegrationTest { config, topic, numRecs, - 60 * 1000); + 120 * 1000); } private Set<KeyValue<String, Long>> fetch(final ReadOnlyWindowStore<String, Long> store, @@ -909,7 +909,7 @@ public class QueryableStateIntegrationTest { 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);
