[flink] branch release-1.11 updated: [FLINK-17891][yarn] Set execution.target=yarn-session in FlinkYarnSessionCli.run()

[kkloudas]

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

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


The following commit(s) were added to refs/heads/release-1.11 by this push:
     new 092fdf8  [FLINK-17891][yarn] Set execution.target=yarn-session in 
FlinkYarnSessionCli.run()
092fdf8 is described below

commit 092fdf880b39387917b9f6fd49344fbb240f741e
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Fri Jun 12 16:43:12 2020 +0200

    [FLINK-17891][yarn] Set execution.target=yarn-session in 
FlinkYarnSessionCli.run()
    
    Currently when starting a yarn session cluster using the yarn-session script
    or the FlinkYarnSessionCli.run() the displayed execution.target is
    yarn-per-job, which is misleading. We fix it by explicitly setting it
    to yarn-session.
    
    This closes #12635.
    
    (cherry picked from commit cc1f1a47123a05a0f5e935a87e683c00c02c5ba4)
---
 .../src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java    | 2 ++
 1 file changed, 2 insertions(+)

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 9507ad8..435cc49 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
@@ -45,6 +45,7 @@ import org.apache.flink.util.FlinkException;
 import org.apache.flink.util.ShutdownHookUtil;
 import org.apache.flink.yarn.YarnClusterDescriptor;
 import org.apache.flink.yarn.configuration.YarnConfigOptions;
+import org.apache.flink.yarn.configuration.YarnDeploymentTarget;
 import org.apache.flink.yarn.executors.YarnJobClusterExecutor;
 import org.apache.flink.yarn.executors.YarnSessionClusterExecutor;
 
@@ -489,6 +490,7 @@ public class FlinkYarnSessionCli extends 
AbstractCustomCommandLine {
 
                final Configuration configuration = 
applyCommandLineOptionsToConfiguration(cmd);
                final ClusterClientFactory<ApplicationId> 
yarnClusterClientFactory = 
clusterClientServiceLoader.getClusterClientFactory(configuration);
+               configuration.set(DeploymentOptions.TARGET, 
YarnDeploymentTarget.SESSION.getName());
 
                final YarnClusterDescriptor yarnClusterDescriptor = 
(YarnClusterDescriptor) 
yarnClusterClientFactory.createClusterDescriptor(configuration);