You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/12/29 12:44:11 UTC
[kafka] branch trunk updated: MINOR: Temporarily disable flaky
Streams EOS system tests (#4355)
This is an automated email from the ASF dual-hosted git repository.
ijuma 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 2cefe3f MINOR: Temporarily disable flaky Streams EOS system tests (#4355)
2cefe3f is described below
commit 2cefe3f0d0f5567b54f3ca5883726fec4f5756eb
Author: Matthias J. Sax <mj...@apache.org>
AuthorDate: Fri Dec 29 04:44:08 2017 -0800
MINOR: Temporarily disable flaky Streams EOS system tests (#4355)
Reviewers: Bill Bejeck <bi...@confluent.io>, Ismael Juma <is...@juma.me.uk>
---
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
['"commits@kafka.apache.org" <co...@kafka.apache.org>'].