mjsax commented on code in PR #13022:
URL: https://github.com/apache/kafka/pull/13022#discussion_r1052583424


##########
tests/kafkatest/tests/streams/streams_upgrade_test.py:
##########
@@ -506,7 +508,7 @@ def do_rolling_bounce(self, processor, counter, 
current_generation):
                     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,

Review Comment:
   I am not 100% sure, but I assume something upstream changed and a new 
version is passed in.
   
   Guess it depends what artifact are used to run the test -- if we build from 
release branches, the `SNAPSHOT` suffix should be contained, but if we run the 
test with release artifacts, the `SNAPSHOT` might have been removed already.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to