This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.0 by this push:
new e6485fd MINOR: Temporarily disable flaky Streams EOS system tests
(#4355)
e6485fd is described below
commit e6485fd58393888adb60983f23855f4edbe62f53
Author: Matthias J. Sax <[email protected]>
AuthorDate: Fri Dec 29 04:44:08 2017 -0800
MINOR: Temporarily disable flaky Streams EOS system tests (#4355)
Reviewers: Bill Bejeck <[email protected]>, Ismael Juma <[email protected]>
---
tests/kafkatest/tests/streams/streams_eos_test.py | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/tests/kafkatest/tests/streams/streams_eos_test.py
b/tests/kafkatest/tests/streams/streams_eos_test.py
index 623d036..27002e9 100644
--- a/tests/kafkatest/tests/streams/streams_eos_test.py
+++ b/tests/kafkatest/tests/streams/streams_eos_test.py
@@ -39,6 +39,7 @@ class StreamsEosTest(KafkaTest):
self.driver = StreamsEosTestDriverService(test_context, self.kafka)
self.test_context = test_context
+ @ignore
@cluster(num_nodes=9)
def test_rebalance_simple(self):
self.run_rebalance(StreamsEosTestJobRunnerService(self.test_context,
self.kafka),
@@ -46,6 +47,7 @@ class StreamsEosTest(KafkaTest):
StreamsEosTestJobRunnerService(self.test_context,
self.kafka),
StreamsEosTestVerifyRunnerService(self.test_context, self.kafka))
+ @ignore
@cluster(num_nodes=9)
def test_rebalance_complex(self):
self.run_rebalance(StreamsComplexEosTestJobRunnerService(self.test_context,
self.kafka),
@@ -77,6 +79,7 @@ class StreamsEosTest(KafkaTest):
verifier.node.account.ssh("grep ALL-RECORDS-DELIVERED %s" %
verifier.STDOUT_FILE, allow_fail=False)
+ @ignore
@cluster(num_nodes=9)
def test_failure_and_recovery(self):
self.run_failure_and_recovery(StreamsEosTestJobRunnerService(self.test_context,
self.kafka),
@@ -84,6 +87,7 @@ class StreamsEosTest(KafkaTest):
StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestVerifyRunnerService(self.test_context, self.kafka))
+ @ignore
@cluster(num_nodes=9)
def test_failure_and_recovery_complex(self):
self.run_failure_and_recovery(StreamsComplexEosTestJobRunnerService(self.test_context,
self.kafka),
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
