kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-4222: Adjust timeout in low resource environments
Date Tue, 09 May 2017 16:23:40 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 78ace3725 -> 5b36adde4


KAFKA-4222: Adjust timeout in low resource environments

Author: Eno Thereska <eno.thereska@gmail.com>

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 <eno.thereska@gmail.com>
Authored: Tue May 9 09:23:35 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
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);
 


Mime
View raw message