kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From damian...@apache.org
Subject kafka git commit: HOTFIX: disable flaky system tests
Date Fri, 07 Jul 2017 08:45:42 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 0046a881d -> 6ea36bc6f


HOTFIX: disable flaky system tests

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Eno Thereska <eno.thereska@gmail.com>, Damian Guy <damian.guy@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 <matthias@confluent.io>
Authored: Fri Jul 7 09:45:37 2017 +0100
Committer: Damian Guy <damian.guy@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),


Mime
View raw message