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: fix KafkaStreams SmokeTest
Date Thu, 15 Sep 2016 15:57:51 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk f197ad499 -> f3bb10413


HOTFIX: fix KafkaStreams SmokeTest

Set the NUM_STREAM_THREADS_CONFIG = 1 in SmokeTestClient as we get locking issues when we
have NUM_STREAM_THREADS_CONFIG > 1 and we have Standby Tasks, i.e., replicas. This is because
the Standby Tasks can be assigned to the same KafkaStreams instance as the active task, hence
the directory is locked

Author: Damian Guy <damian.guy@gmail.com>

Reviewers: Eno Thereska, Guozhang Wang

Closes #1861 from dguy/fix-smoketest


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

Branch: refs/heads/trunk
Commit: f3bb10413d11525a396851eb7e6b9d75b8c6fe23
Parents: f197ad4
Author: Damian Guy <damian.guy@gmail.com>
Authored: Thu Sep 15 08:57:48 2016 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Thu Sep 15 08:57:48 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/streams/smoketest/SmokeTestClient.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/f3bb1041/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
b/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
index ba71e05..5302900 100644
--- a/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
+++ b/streams/src/test/java/org/apache/kafka/streams/smoketest/SmokeTestClient.java
@@ -85,7 +85,7 @@ public class SmokeTestClient extends SmokeTestUtil {
         props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, kafka);
         props.put(StreamsConfig.ZOOKEEPER_CONNECT_CONFIG, zookeeper);
         props.put(StreamsConfig.TIMESTAMP_EXTRACTOR_CLASS_CONFIG, TestTimestampExtractor.class.getName());
-        props.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 3);
+        props.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 1);
         props.put(StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG, 2);
         props.put(StreamsConfig.BUFFERED_RECORDS_PER_PARTITION_CONFIG, 100);
         props.put(StreamsConfig.REPLICATION_FACTOR_CONFIG, 2);


Mime
View raw message