[kafka] branch trunk updated: MINOR: report streams benchmarks separately (#5275)

[gu...@apache.org]

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 <vv...@users.noreply.github.com>
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 <wa...@gmail.com>
---
 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