affo commented on code in PR #24471:
URL: https://github.com/apache/flink/pull/24471#discussion_r1530613302
##########
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkDistribution.java:
##########
@@ -234,10 +234,7 @@ public JobID submitJob(final JobSubmission jobSubmission,
Duration timeout) thro
LOG.info("Running {}.", commands.stream().collect(Collectors.joining("
")));
- final Pattern pattern =
- jobSubmission.isDetached()
- ? Pattern.compile("Job has been submitted with JobID
(.*)")
- : Pattern.compile("Job with JobID (.*) has finished.");
+ final Pattern pattern = Pattern.compile("Job has been submitted with
JobID (.*)");
Review Comment:
It used to be, as apparently that string matching is now obsolete.
With latest changes this is not relevant anymore 👍
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
