This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.1 by this push:
new 59e25cf HOTFIX: fix bug in VP test where it greps for the wrong log
message (#7643)
59e25cf is described below
commit 59e25cf48e182461235cc60c1d647b94fa011659
Author: A. Sophie Blee-Goldman <[email protected]>
AuthorDate: Mon Nov 4 19:00:27 2019 -0800
HOTFIX: fix bug in VP test where it greps for the wrong log message (#7643)
Reviewers: Guozhang Wang <[email protected]>
---
tests/kafkatest/tests/streams/streams_upgrade_test.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tests/kafkatest/tests/streams/streams_upgrade_test.py
b/tests/kafkatest/tests/streams/streams_upgrade_test.py
index 5336651..24d3a62 100644
--- a/tests/kafkatest/tests/streams/streams_upgrade_test.py
+++ b/tests/kafkatest/tests/streams/streams_upgrade_test.py
@@ -454,11 +454,11 @@ class StreamsUpgradeTest(Test):
monitors[second_other_processor] = second_other_monitor
if len(self.old_processors) > 0:
- log_monitor.wait_until("Sent a version 5 subscription
and got version 4 assignment back (successful version probing). Downgrade
subscription metadata to commonly supported version and trigger new rebalance.",
+ log_monitor.wait_until("Sent a version 5 subscription
and got version 4 assignment back (successful version probing). Downgrade
subscription metadata to commonly supported version 4 and trigger new
rebalance.",
timeout_sec=60,
err_msg="Could not detect
'successful version probing' at upgrading node " + str(node.account))
else:
- log_monitor.wait_until("Sent a version 5 subscription
and got version 4 assignment back (successful version probing). Downgrade
subscription metadata to commonly supported version and trigger new rebalance.",
+ log_monitor.wait_until("Sent a version 5 subscription
and got version 4 assignment back (successful version probing). Downgrade
subscription metadata to commonly supported version 5 and trigger new
rebalance.",
timeout_sec=60,
err_msg="Could not detect
'successful version probing with upgraded leader' at upgrading node " +
str(node.account))
first_other_monitor.wait_until("Sent a version 4
subscription and group.s latest commonly supported version is 5 (successful
version probing and end of rolling upgrade). Upgrading subscription metadata
version to 5 for next rebalance.",
