Repository: kafka Updated Branches: refs/heads/trunk c4282371d -> 39f1c3ff8
MINOR: Ignoring streams tests until there is fix for KAFKA-3354 Per discussion with guozhangwang, `ignore` failing streams system tests until fix for KAFKA-3354 is checked in. Author: Geoff Anderson <[email protected]> Reviewers: Guozhang Wang Closes #1031 from granders/ignore-streams-systest Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/39f1c3ff Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/39f1c3ff Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/39f1c3ff Branch: refs/heads/trunk Commit: 39f1c3ff83879e3d00ea4567db15181c746deba2 Parents: c428237 Author: Geoff Anderson <[email protected]> Authored: Tue Mar 8 21:40:40 2016 -0800 Committer: Guozhang Wang <[email protected]> Committed: Tue Mar 8 21:40:40 2016 -0800 ---------------------------------------------------------------------- tests/kafkatest/tests/streams_bounce_test.py | 4 +++- tests/kafkatest/tests/streams_smoke_test.py | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/39f1c3ff/tests/kafkatest/tests/streams_bounce_test.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/tests/streams_bounce_test.py b/tests/kafkatest/tests/streams_bounce_test.py index 2b9c4d6..5523909 100644 --- a/tests/kafkatest/tests/streams_bounce_test.py +++ b/tests/kafkatest/tests/streams_bounce_test.py @@ -13,9 +13,10 @@ # See the License for the specific language governing permissions and # limitations under the License. +from ducktape.mark import ignore + from kafkatest.tests.kafka_test import KafkaTest from kafkatest.services.streams import StreamsSmokeTestDriverService, StreamsSmokeTestJobRunnerService -from ducktape.utils.util import wait_until import time class StreamsBounceTest(KafkaTest): @@ -40,6 +41,7 @@ class StreamsBounceTest(KafkaTest): self.driver = StreamsSmokeTestDriverService(test_context, self.kafka) self.processor1 = StreamsSmokeTestJobRunnerService(test_context, self.kafka) + @ignore def test_bounce(self): """ Start a smoke test client, then abort (kill -9) and restart it a few times. http://git-wip-us.apache.org/repos/asf/kafka/blob/39f1c3ff/tests/kafkatest/tests/streams_smoke_test.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/tests/streams_smoke_test.py b/tests/kafkatest/tests/streams_smoke_test.py index 48e4db8..ea05c5f 100644 --- a/tests/kafkatest/tests/streams_smoke_test.py +++ b/tests/kafkatest/tests/streams_smoke_test.py @@ -13,9 +13,10 @@ # See the License for the specific language governing permissions and # limitations under the License. +from ducktape.mark import ignore + from kafkatest.tests.kafka_test import KafkaTest from kafkatest.services.streams import StreamsSmokeTestDriverService, StreamsSmokeTestJobRunnerService -from ducktape.utils.util import wait_until import time class StreamsSmokeTest(KafkaTest): @@ -43,6 +44,7 @@ class StreamsSmokeTest(KafkaTest): self.processor3 = StreamsSmokeTestJobRunnerService(test_context, self.kafka) self.processor4 = StreamsSmokeTestJobRunnerService(test_context, self.kafka) + @ignore def test_streams(self): """ Start a few smoke test clients, then repeat start a new one, stop (cleanly) running one a few times.
