You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2020/06/16 07:36:43 UTC
[flink] branch release-1.11 updated: [FLINK-17891][yarn] Set
execution.target=yarn-session in FlinkYarnSessionCli.run()
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 <kk...@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);