You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2022/12/27 18:09:40 UTC
[kafka] branch trunk updated: MINOR: fix expected version in streams upgrade test (#13022)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 9e71f9cc7df MINOR: fix expected version in streams upgrade test (#13022)
9e71f9cc7df is described below
commit 9e71f9cc7df1cb67774545dfa8b79a00f6a600e9
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Tue Dec 27 10:09:27 2022 -0800
MINOR: fix expected version in streams upgrade test (#13022)
Co-authored-by: Lucas Brutschy <lu...@users.noreply.github.com>
Reviewers: Suhas Satish <ss...@confluent.io>, Lucas Brutschy <lb...@confluent.io>, John Roesler <jo...@confluent.io>
---
tests/kafkatest/tests/streams/streams_upgrade_test.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/tests/kafkatest/tests/streams/streams_upgrade_test.py b/tests/kafkatest/tests/streams/streams_upgrade_test.py
index 961be68acfc..ffadc454d0c 100644
--- a/tests/kafkatest/tests/streams/streams_upgrade_test.py
+++ b/tests/kafkatest/tests/streams/streams_upgrade_test.py
@@ -511,6 +511,8 @@ class StreamsUpgradeTest(Test):
first_other_node = first_other_processor.node
second_other_node = second_other_processor.node
+ kafka_version_str = self.get_version_string(str(DEV_VERSION))
+
with first_other_node.account.monitor_log(first_other_processor.LOG_FILE) as first_other_monitor:
with second_other_node.account.monitor_log(second_other_processor.LOG_FILE) as second_other_monitor:
# stop processor
@@ -528,7 +530,7 @@ class StreamsUpgradeTest(Test):
self.upgraded_processors.append(processor)
# checking for the dev version which should be the only SNAPSHOT
- log_monitor.wait_until("Kafka version.*" + self.base_version_number + ".*SNAPSHOT",
+ log_monitor.wait_until(kafka_version_str,
timeout_sec=60,
err_msg="Could not detect Kafka Streams version " + str(DEV_VERSION) + " in " + str(node.account))
log_monitor.offset = 5