root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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 <wangguoz@gmail.com>
This commit is contained in:
John Roesler 2018-06-22 19:10:06 -05:00 committed by Guozhang Wang
parent 954be11bf2
commit 74502710b3
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
View File

@ -51,7 +51,11 @@ class StreamsSimpleBenchmarkTest(Test):
self.replication = 1 self.replication = 1
@cluster(num_nodes=12) @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): def test_simple_benchmark(self, test, scale):
""" """
Run simple Kafka Streams benchmark Run simple Kafka Streams benchmark