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
Reviewers: Guozhang Wang
Closes from dguy/fix-system-test
@@ -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
