root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity

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
This commit is contained in:
Matthias J. Sax 2017-07-07 09:45:37 +01:00 committed by Damian Guy
parent 0046a881d3
commit 6ea36bc6fb
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/kafkatest/tests/streams/streams_eos_test.py
View File

@ -14,6 +14,7 @@
# limitations under the License. # limitations under the License.
from ducktape.mark.resource import cluster from ducktape.mark.resource import cluster
from ducktape.mark import ignore
from kafkatest.tests.kafka_test import KafkaTest from kafkatest.tests.kafka_test import KafkaTest
from kafkatest.services.streams import StreamsEosTestDriverService, StreamsEosTestJobRunnerService, \ from kafkatest.services.streams import StreamsEosTestDriverService, StreamsEosTestJobRunnerService, \
@ -39,12 +40,14 @@ class StreamsEosTest(KafkaTest):
self.driver = StreamsEosTestDriverService(test_context, self.kafka) self.driver = StreamsEosTestDriverService(test_context, self.kafka)
self.test_context = test_context self.test_context = test_context
@ignore
@cluster(num_nodes=8) @cluster(num_nodes=8)
def test_rebalance_simple(self): def test_rebalance_simple(self):
self.run_rebalance(StreamsEosTestJobRunnerService(self.test_context, self.kafka), self.run_rebalance(StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestJobRunnerService(self.test_context, self.kafka), StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestVerifyRunnerService(self.test_context, self.kafka)) StreamsEosTestVerifyRunnerService(self.test_context, self.kafka))
@ignore
@cluster(num_nodes=8) @cluster(num_nodes=8)
def test_rebalance_complex(self): def test_rebalance_complex(self):
self.run_rebalance(StreamsComplexEosTestJobRunnerService(self.test_context, self.kafka), 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) verifier.node.account.ssh("grep ALL-RECORDS-DELIVERED %s" % verifier.STDOUT_FILE, allow_fail=False)
@ignore
@cluster(num_nodes=8) @cluster(num_nodes=8)
def test_failure_and_recovery(self): def test_failure_and_recovery(self):
self.run_failure_and_recovery(StreamsEosTestJobRunnerService(self.test_context, self.kafka), self.run_failure_and_recovery(StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestJobRunnerService(self.test_context, self.kafka), StreamsEosTestJobRunnerService(self.test_context, self.kafka),
StreamsEosTestVerifyRunnerService(self.test_context, self.kafka)) StreamsEosTestVerifyRunnerService(self.test_context, self.kafka))
@ignore
@cluster(num_nodes=8) @cluster(num_nodes=8)
def test_failure_and_recovery_complex(self): def test_failure_and_recovery_complex(self):
self.run_failure_and_recovery(StreamsComplexEosTestJobRunnerService(self.test_context, self.kafka), self.run_failure_and_recovery(StreamsComplexEosTestJobRunnerService(self.test_context, self.kafka),