fix

Author: WTZ468071157

launcher/src/main/java/com/dtstack/flink/sql/launcher/ClusterClientFactory.java

@@ -117,14 +117,13 @@ public static ClusterClient createYarnSessionClient(Options launcherOptions) {
 
                 LOG.info("applicationId={}", applicationId.toString());
 
-                if (config.getString("high-availability.cluster-id", null) == null) {
-                    config.setString("high-availability.cluster-id", applicationId.toString());
-                }
-
                 if (StringUtils.isEmpty(applicationId.toString())) {
                     throw new RuntimeException("No flink session found on yarn cluster.");
                 }
 
+                if (config.getString("high-availability.cluster-id", null) == null) {
+                    config.setString("high-availability.cluster-id", applicationId.toString());
+                }
                 LOG.info("current config detail:\n{}", config);
 
                 AbstractYarnClusterDescriptor clusterDescriptor = new YarnClusterDescriptor(config, yarnConf, flinkConfDir, yarnClient, false);