From 399a99074fe623f5dda1c9fdc603f2cccfcac6bb Mon Sep 17 00:00:00 2001 From: Damian Guy Date: Mon, 23 Jan 2017 11:46:38 +0000 Subject: [PATCH 1/2] add arg to system test --- tests/kafkatest/services/streams.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/kafkatest/services/streams.py b/tests/kafkatest/services/streams.py index 9250cd7b94375..aac3bf8cba21d 100644 --- a/tests/kafkatest/services/streams.py +++ b/tests/kafkatest/services/streams.py @@ -149,14 +149,14 @@ def __init__(self, test_context, kafka, command): class StreamsSmokeTestDriverService(StreamsSmokeTestBaseService): def __init__(self, test_context, kafka): - super(StreamsSmokeTestDriverService, self).__init__(test_context, kafka, "run") + super(StreamsSmokeTestDriverService, self).__init__(test_context, kafka, "org.apache.kafka.streams.smoketest.StreamsSmokeTest", "run") class StreamsSmokeTestJobRunnerService(StreamsSmokeTestBaseService): def __init__(self, test_context, kafka): - super(StreamsSmokeTestJobRunnerService, self).__init__(test_context, kafka, "process") + super(StreamsSmokeTestJobRunnerService, self).__init__(test_context, kafka, "org.apache.kafka.streams.smoketest.StreamsSmokeTest", "process") class StreamsSmokeTestShutdownDeadlockService(StreamsSmokeTestBaseService): def __init__(self, test_context, kafka): - super(StreamsSmokeTestShutdownDeadlockService, self).__init__(test_context, kafka, "close-deadlock-test") + super(StreamsSmokeTestShutdownDeadlockService, self).__init__(test_context, kafka, "org.apache.kafka.streams.smoketest.StreamsSmokeTest", "close-deadlock-test") From 75165327a1df096047a0d97abd75a6f303fa1e2c Mon Sep 17 00:00:00 2001 From: Damian Guy Date: Mon, 23 Jan 2017 12:08:59 +0000 Subject: [PATCH 2/2] blah --- tests/kafkatest/services/streams.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/kafkatest/services/streams.py b/tests/kafkatest/services/streams.py index aac3bf8cba21d..f0b17cd8bd45a 100644 --- a/tests/kafkatest/services/streams.py +++ b/tests/kafkatest/services/streams.py @@ -118,7 +118,7 @@ def start_cmd(self, node): cmd = "( export KAFKA_LOG4J_OPTS=\"-Dlog4j.configuration=file:%(log4j)s\"; " \ "INCLUDE_TEST_JARS=true %(kafka_run_class)s %(streams_class_name)s " \ - " %(kafka)s %(state_dir)s %(user_test_args)s" \ + " %(user_test_args)s %(kafka)s %(state_dir)s" \ " & echo $! >&3 ) 1>> %(stdout)s 2>> %(stderr)s 3> %(pidfile)s" % args return cmd @@ -149,14 +149,14 @@ def __init__(self, test_context, kafka, command): class StreamsSmokeTestDriverService(StreamsSmokeTestBaseService): def __init__(self, test_context, kafka): - super(StreamsSmokeTestDriverService, self).__init__(test_context, kafka, "org.apache.kafka.streams.smoketest.StreamsSmokeTest", "run") + super(StreamsSmokeTestDriverService, self).__init__(test_context, kafka, "run") class StreamsSmokeTestJobRunnerService(StreamsSmokeTestBaseService): def __init__(self, test_context, kafka): - super(StreamsSmokeTestJobRunnerService, self).__init__(test_context, kafka, "org.apache.kafka.streams.smoketest.StreamsSmokeTest", "process") + super(StreamsSmokeTestJobRunnerService, self).__init__(test_context, kafka, "process") class StreamsSmokeTestShutdownDeadlockService(StreamsSmokeTestBaseService): def __init__(self, test_context, kafka): - super(StreamsSmokeTestShutdownDeadlockService, self).__init__(test_context, kafka, "org.apache.kafka.streams.smoketest.StreamsSmokeTest", "close-deadlock-test") + super(StreamsSmokeTestShutdownDeadlockService, self).__init__(test_context, kafka, "close-deadlock-test")