kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: Reverted timeouts to larger values
Date Thu, 05 May 2016 20:50:26 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 a9df2e7ca -> 940468011


HOTFIX: Reverted timeouts to larger values

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

Reviewers: Ismael Juma, Guozhang Wang

Closes #1324 from enothereska/hotfix-timeouts

(cherry picked from commit 7f4e3ccde820eedd962b4cfd3abaecd8a49b83a8)
Signed-off-by: Guozhang Wang <wangguoz@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/94046801
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/94046801
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/94046801

Branch: refs/heads/0.10.0
Commit: 940468011a6d127e823c7a59709c4381fb31694f
Parents: a9df2e7
Author: Eno Thereska <eno.thereska@gmail.com>
Authored: Thu May 5 13:50:15 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu May 5 13:50:22 2016 -0700

----------------------------------------------------------------------
 .../apache/kafka/streams/integration/FanoutIntegrationTest.java    | 2 +-
 .../org/apache/kafka/streams/integration/JoinIntegrationTest.java  | 2 +-
 .../kafka/streams/integration/MapFunctionIntegrationTest.java      | 2 +-
 .../kafka/streams/integration/PassThroughIntegrationTest.java      | 2 +-
 .../apache/kafka/streams/integration/WordCountIntegrationTest.java | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/94046801/streams/src/test/java/org/apache/kafka/streams/integration/FanoutIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/FanoutIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/FanoutIntegrationTest.java
index a7b4785..2e11cd2 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/FanoutIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/FanoutIntegrationTest.java
@@ -135,7 +135,7 @@ public class FanoutIntegrationTest {
         IntegrationTestUtils.produceValuesSynchronously(INPUT_TOPIC_A, inputValues, producerConfig);
 
         // Give the stream processing application some time to do its work.
-        Thread.sleep(5000);
+        Thread.sleep(10000);
         streams.close();
 
         //

http://git-wip-us.apache.org/repos/asf/kafka/blob/94046801/streams/src/test/java/org/apache/kafka/streams/integration/JoinIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/JoinIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/JoinIntegrationTest.java
index 1fc0ba6..93e31e2 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/JoinIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/JoinIntegrationTest.java
@@ -247,7 +247,7 @@ public class JoinIntegrationTest {
         IntegrationTestUtils.produceKeyValuesSynchronously(USER_CLICKS_TOPIC, userClicks,
userClicksProducerConfig);
 
         // Give the stream processing application some time to do its work.
-        Thread.sleep(5000);
+        Thread.sleep(10000);
         streams.close();
 
         //

http://git-wip-us.apache.org/repos/asf/kafka/blob/94046801/streams/src/test/java/org/apache/kafka/streams/integration/MapFunctionIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/MapFunctionIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/MapFunctionIntegrationTest.java
index 47c00c1..31ac400 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/MapFunctionIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/MapFunctionIntegrationTest.java
@@ -108,7 +108,7 @@ public class MapFunctionIntegrationTest {
         IntegrationTestUtils.produceValuesSynchronously(DEFAULT_INPUT_TOPIC, inputValues,
producerConfig);
 
         // Give the stream processing application some time to do its work.
-        Thread.sleep(5000);
+        Thread.sleep(10000);
         streams.close();
 
         //

http://git-wip-us.apache.org/repos/asf/kafka/blob/94046801/streams/src/test/java/org/apache/kafka/streams/integration/PassThroughIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/PassThroughIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/PassThroughIntegrationTest.java
index 2627a3a..e126ed8 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/PassThroughIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/PassThroughIntegrationTest.java
@@ -95,7 +95,7 @@ public class PassThroughIntegrationTest {
         IntegrationTestUtils.produceValuesSynchronously(DEFAULT_INPUT_TOPIC, inputValues,
producerConfig);
 
         // Give the stream processing application some time to do its work.
-        Thread.sleep(5000);
+        Thread.sleep(10000);
         streams.close();
 
         //

http://git-wip-us.apache.org/repos/asf/kafka/blob/94046801/streams/src/test/java/org/apache/kafka/streams/integration/WordCountIntegrationTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/WordCountIntegrationTest.java
b/streams/src/test/java/org/apache/kafka/streams/integration/WordCountIntegrationTest.java
index 5c32a6c..c8583d1 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/WordCountIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/WordCountIntegrationTest.java
@@ -134,7 +134,7 @@ public class WordCountIntegrationTest {
         //
         // Step 3: Verify the application's output data.
         //
-        Thread.sleep(5000);
+        Thread.sleep(10000);
         streams.close();
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, CLUSTER.bootstrapServers());


Mime
View raw message