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

aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit b8153d3b7dfdcaf4660f1531b3e984a63c5c1741
Author: Aljoscha Krettek <aljos...@apache.org>
AuthorDate: Sat Dec 7 17:28:31 2019 +0100

    [hotfix] Remove "shutdown if attached" option from "all" YARN options
    
    Adding this option here means that the check in
    isYarnPropertiesFileMode() will mistakenly think that "shutown if
    attached" is a YARN option and therefore not execute an attached job
    with this option on an existing YARN session.
---
 .../src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java    | 2 --
 1 file changed, 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 2e035e7..fd97496 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
@@ -85,7 +85,6 @@ import java.util.concurrent.TimeUnit;
 import java.util.stream.Stream;
 
 import static org.apache.flink.client.cli.CliFrontendParser.DETACHED_OPTION;
-import static 
org.apache.flink.client.cli.CliFrontendParser.SHUTDOWN_IF_ATTACHED_OPTION;
 import static 
org.apache.flink.client.cli.CliFrontendParser.YARN_DETACHED_OPTION;
 import static 
org.apache.flink.configuration.HighAvailabilityOptions.HA_CLUSTER_ID;
 import static org.apache.flink.util.Preconditions.checkNotNull;
@@ -217,7 +216,6 @@ public class FlinkYarnSessionCli extends 
AbstractCustomCommandLine {
                allOptions.addOption(slots);
                allOptions.addOption(dynamicproperties);
                allOptions.addOption(DETACHED_OPTION);
-               allOptions.addOption(SHUTDOWN_IF_ATTACHED_OPTION);
                allOptions.addOption(YARN_DETACHED_OPTION);
                allOptions.addOption(name);
                allOptions.addOption(applicationId);

Reply via email to