This is an automated email from the ASF dual-hosted git repository. guozhang pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/kafka.git The following commit(s) were added to refs/heads/trunk by this push: new 7450271 MINOR: report streams benchmarks separately (#5275) 7450271 is described below commit 74502710b383175a760b563fb67dad295d97ec5a Author: John Roesler AuthorDate: Fri Jun 22 19:10:06 2018 -0500 MINOR: report streams benchmarks separately (#5275) Specify each benchmark as a separate test so that we can see the results reported independently. Reviewers: Guozhang Wang --- tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py b/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py index b1cfb4e..2f87f4a 100644 --- a/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py +++ b/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py @@ -51,7 +51,11 @@ class StreamsSimpleBenchmarkTest(Test): self.replication = 1 @cluster(num_nodes=12) - @matrix(test=["consume", "consumeproduce", "streams-simple", "streams-count", "streams-join"], scale=[1]) + @matrix(test=["consume", "consumeproduce", + "streamprocess", "streamprocesswithsink", "streamprocesswithstatestore", "streamprocesswithwindowstore", + "streamcount", "streamcountwindowed", + "streamtablejoin", "streamstreamjoin", "tabletablejoin"], + scale=[1]) def test_simple_benchmark(self, test, scale): """ Run simple Kafka Streams benchmark