You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2018/04/27 20:40:30 UTC
[kafka] branch trunk updated: HOTFIX: rename run_test to execute in
streams simple benchmark (#4941)
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 b2e0812 HOTFIX: rename run_test to execute in streams simple benchmark (#4941)
b2e0812 is described below
commit b2e0812f6946f88cef2cdffb0be603b4b769033a
Author: Guozhang Wang <wa...@gmail.com>
AuthorDate: Fri Apr 27 13:40:24 2018 -0700
HOTFIX: rename run_test to execute in streams simple benchmark (#4941)
---
.../benchmarks/streams/streams_simple_benchmark_test.py | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py b/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
index 6e6d676..b1cfb4e 100644
--- a/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
+++ b/tests/kafkatest/benchmarks/streams/streams_simple_benchmark_test.py
@@ -107,22 +107,22 @@ class StreamsSimpleBenchmarkTest(Test):
if test == ALL_TEST:
for single_test in STREAMS_SIMPLE_TESTS + STREAMS_COUNT_TESTS + STREAMS_JOIN_TESTS:
- self.run_test(single_test, scale)
+ self.execute(single_test, scale)
elif test == STREAMS_SIMPLE_TEST:
for single_test in STREAMS_SIMPLE_TESTS:
- self.run_test(single_test, scale)
+ self.execute(single_test, scale)
elif test == STREAMS_COUNT_TEST:
for single_test in STREAMS_COUNT_TESTS:
- self.run_test(single_test, scale)
+ self.execute(single_test, scale)
elif test == STREAMS_JOIN_TEST:
for single_test in STREAMS_JOIN_TESTS:
- self.run_test(single_test, scale)
+ self.execute(single_test, scale)
else:
- self.run_test(test, scale)
+ self.execute(test, scale)
return self.final
- def run_test(self, test, scale):
+ def execute(self, test, scale):
################
# RUN PHASE
--
To stop receiving notification emails like this one, please contact
guozhang@apache.org.