[flink] branch release-1.15 updated: [FLINK-24960][yarn-tests] change order of statements to avoid race condition

[mapohl]

This is an automated email from the ASF dual-hosted git repository.

mapohl pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.15 by this push:
     new 96c400cf909 [FLINK-24960][yarn-tests] change order of statements to 
avoid race condition
96c400cf909 is described below

commit 96c400cf909a4af941a54fa663758d73bb0f9679
Author: Niklas Semmler <nik...@ververica.com>
AuthorDate: Tue May 31 13:26:47 2022 +0200

    [FLINK-24960][yarn-tests] change order of statements to avoid race condition
---
 .../main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java 
b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
index b43dde42569..0c865eb3a40 100644
--- 
a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
+++ 
b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
@@ -611,10 +611,12 @@ public class FlinkYarnSessionCli extends AbstractYarnCli {
                     yarnApplicationId = clusterClient.getClusterId();
 
                     try {
+                        // Other threads use the Yarn properties file to 
connect to the YARN session
+                        writeYarnPropertiesFile(yarnApplicationId, 
dynamicPropertiesEncoded);
+
+                        // Multiple tests match on the following output
                         System.out.println(
                                 "JobManager Web Interface: " + 
clusterClient.getWebInterfaceURL());
-
-                        writeYarnPropertiesFile(yarnApplicationId, 
dynamicPropertiesEncoded);
                     } catch (Exception e) {
                         try {
                             clusterClient.close();