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/04/23 15:23:46 UTC
kafka git commit: KAFKA-4564;
Follow-up to fix test_timeout_on_pre_010_brokers system test failure
Repository: kafka
Updated Branches:
refs/heads/trunk 19f266d40 -> 1fbb8cfaf
KAFKA-4564; Follow-up to fix test_timeout_on_pre_010_brokers system test failure
Author: Matthias J. Sax <ma...@confluent.io>
Reviewers: Eno Thereska <en...@confluent.io>, Ismael Juma <is...@juma.me.uk>
Closes #2897 from mjsax/KAFKA-4564-follow-up
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1fbb8cfa
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/1fbb8cfa
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/1fbb8cfa
Branch: refs/heads/trunk
Commit: 1fbb8cfafa64307f94de09e4a14217a69f01cea0
Parents: 19f266d
Author: Matthias J. Sax <ma...@confluent.io>
Authored: Sun Apr 23 16:23:48 2017 +0100
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Sun Apr 23 16:23:48 2017 +0100
----------------------------------------------------------------------
tests/kafkatest/tests/streams/streams_broker_compatibility_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/1fbb8cfa/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py b/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
index 9df7663..a5bdbc6 100644
--- a/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
+++ b/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
@@ -98,7 +98,7 @@ class StreamsBrokerCompatibility(Test):
self.processor.node.account.ssh(self.processor.start_cmd(self.processor.node))
with self.processor.node.account.monitor_log(self.processor.STDERR_FILE) as monitor:
- monitor.wait_until('Exception in thread "main" org.apache.kafka.streams.errors.StreamsException: Could not find any available broker.',
+ monitor.wait_until('Exception in thread "main" org.apache.kafka.streams.errors.BrokerNotFoundException: Could not find any available broker.',
timeout_sec=60,
err_msg="Never saw 'no available broker' error message " + str(self.processor.node.account))