You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2017/07/07 08:45:42 UTC
kafka git commit: HOTFIX: disable flaky system tests
Repository: kafka
Updated Branches:
refs/heads/trunk 0046a881d -> 6ea36bc6f
HOTFIX: disable flaky system tests
Author: Matthias J. Sax <ma...@confluent.io>
Reviewers: Eno Thereska <en...@gmail.com>, Damian Guy <da...@gmail.com>
Closes #3497 from mjsax/disable-flaky-system-tests
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6ea36bc6
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6ea36bc6
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6ea36bc6
Branch: refs/heads/trunk
Commit: 6ea36bc6fbd7bf73dbbd0e097353f6caf89b9488
Parents: 0046a88
Author: Matthias J. Sax <ma...@confluent.io>
Authored: Fri Jul 7 09:45:37 2017 +0100
Committer: Damian Guy <da...@gmail.com>
Committed: Fri Jul 7 09:45:37 2017 +0100
----------------------------------------------------------------------
tests/kafkatest/tests/streams/streams_eos_test.py | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/6ea36bc6/tests/kafkatest/tests/streams/streams_eos_test.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/tests/streams/streams_eos_test.py b/tests/kafkatest/tests/streams/streams_eos_test.py
index be2c4f8..60dc4b1 100644
--- a/tests/kafkatest/tests/streams/streams_eos_test.py
+++ b/tests/kafkatest/tests/streams/streams_eos_test.py
@@ -14,6 +14,7 @@
# limitations under the License.
from ducktape.mark.resource import cluster
+from ducktape.mark import ignore
from kafkatest.tests.kafka_test import KafkaTest
from kafkatest.services.streams import StreamsEosTestDriverService, StreamsEosTestJobRunnerService, \
@@ -39,12 +40,14 @@ class StreamsEosTest(KafkaTest):
self.driver = StreamsEosTestDriverService(test_context, self.kafka)
self.test_context = test_context
+ @ignore
@cluster(num_nodes=8)
def test_rebalance_simple(self):
self.run_rebalance(StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestVerifyRunnerService(self.test_context, self.kafka))
+ @ignore
@cluster(num_nodes=8)
def test_rebalance_complex(self):
self.run_rebalance(StreamsComplexEosTestJobRunnerService(self.test_context, self.kafka),
@@ -85,12 +88,14 @@ class StreamsEosTest(KafkaTest):
verifier.node.account.ssh("grep ALL-RECORDS-DELIVERED %s" % verifier.STDOUT_FILE, allow_fail=False)
+ @ignore
@cluster(num_nodes=8)
def test_failure_and_recovery(self):
self.run_failure_and_recovery(StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestVerifyRunnerService(self.test_context, self.kafka))
+ @ignore
@cluster(num_nodes=8)
def test_failure_and_recovery_complex(self):
self.run_failure_and_recovery(StreamsComplexEosTestJobRunnerService(self.test_context, self.kafka),