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

Rmoved stray allow_fail. kafka_benchmark_test -> benchmark_test

This commit is contained in:
Geoff Anderson 2015-06-15 17:11:49 -07:00
parent f469f84e6d
commit 0f75187458
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/kafkatest/services/kafka.py
View File

@ -92,7 +92,7 @@ class KafkaService(Service):
node.account.ssh("rm -f /mnt/kafka.pid", allow_fail=False)
def clean_node(self, node):
node.account.ssh("rm -rf /mnt/kafka-logs /mnt/kafka.properties /mnt/kafka.log", allow_fail=False)
node.account.ssh("rm -rf /mnt/kafka-logs /mnt/kafka.properties /mnt/kafka.log /mnt/kafka.pid", allow_fail=False)
def create_topic(self, topic_cfg):
node = self.nodes[0] # any node is fine here
@ -191,7 +191,7 @@ class KafkaService(Service):
def restart_node(self, node, wait_sec=0, clean_shutdown=True):
"""Restart the given node, waiting wait_sec in between stopping and starting up again."""
self.stop_node(node, clean_shutdown, allow_fail=True)
self.stop_node(node, clean_shutdown)
time.sleep(wait_sec)
self.start_node(node)

2
tests/kafkatest/tests/kafka_benchmark_test.py → tests/kafkatest/tests/benchmark_test.py
View File

@ -18,7 +18,7 @@ from kafkatest.tests.kafka_test import KafkaTest
from kafkatest.services.performance import ProducerPerformanceService, ConsumerPerformanceService, EndToEndLatencyService
class KafkaBenchmark(KafkaTest):
class Benchmark(KafkaTest):
'''A benchmark of Kafka producer/consumer performance. This replicates the test
run here:
https://engineering.linkedin.com/kafka/benchmarking-apache-kafka-2-million-writes-second-three-cheap-machines