kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: HOTFIX: reduce streams benchmark input records to 10 million
Date Wed, 23 Aug 2017 19:53:06 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 3b7e10455 -> 99eebc840


HOTFIX: reduce streams benchmark input records to 10 million

We are occasionally hitting some timeouts due to processing not finishing. So rather than
failing the build for these reasons it would be better to reduce the runtime.

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

Reviewers: Guozhang Wang <wangguoz@gmail.com>

Closes #3725 from dguy/fix-system-test


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

Branch: refs/heads/trunk
Commit: 99eebc840485d5b3352bc9e2f9230a33303cc080
Parents: 3b7e104
Author: Damian Guy <damian.guy@gmail.com>
Authored: Wed Aug 23 20:53:00 2017 +0100
Committer: Damian Guy <damian.guy@gmail.com>
Committed: Wed Aug 23 20:53:00 2017 +0100

----------------------------------------------------------------------
 .../kafkatest/benchmarks/streams/streams_simple_benchmark_test.py  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/99eebc84/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py b/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
index 258b7c0..4cc3976 100644
--- a/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
+++ b/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
@@ -30,7 +30,7 @@ class StreamsSimpleBenchmarkTest(Test):
 
     def __init__(self, test_context):
         super(StreamsSimpleBenchmarkTest, self).__init__(test_context)
-        self.num_records = 20000000L
+        self.num_records = 10000000L
         self.replication = 1
         self.num_threads = 1
 


Mime
View raw message