From 0f8b63fc244fd2d8c5abc61f2e997638b0c3a9e2 Mon Sep 17 00:00:00 2001 From: Ralph Su Date: Wed, 28 Feb 2018 19:03:34 +0800 Subject: [PATCH] [FLINK-6119]: ClusterClient Detach Mode configurable in client-api Author: ralphsu@apache.org This closes #FLINK-6119 --- .../java/org/apache/flink/client/program/ClusterClient.java | 5 ++++- .../java/org/apache/flink/configuration/ConfigConstants.java | 5 +++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java b/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java index e2efbac523ceb..d52f6d1b4cb54 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java +++ b/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java @@ -24,6 +24,7 @@ import org.apache.flink.api.common.Plan; import org.apache.flink.api.common.accumulators.AccumulatorHelper; import org.apache.flink.api.common.time.Time; +import org.apache.flink.configuration.ConfigConstants; import org.apache.flink.configuration.Configuration; import org.apache.flink.core.fs.Path; import org.apache.flink.optimizer.CompilerException; @@ -172,7 +173,9 @@ public ClusterClient(Configuration flinkConfig, HighAvailabilityServices highAva flinkConfig, log); - this.highAvailabilityServices = Preconditions.checkNotNull(highAvailabilityServices); + this.highAvailabilityServices = Preconditions.checkNotNull(highAvailabilityServices); + this.detachedJobSubmission = flinkConfig.getBoolean(ConfigConstants.FLINK_DETACHED_JOB_SUBMISSION, + ConfigConstants.DEFAULT_FLINK_DETACHED_JOB_SUBMISSION); } // ------------------------------------------------------------------------ diff --git a/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java b/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java index b716d9ec4a36c..db15f4fe2e13b 100644 --- a/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java +++ b/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java @@ -1032,6 +1032,8 @@ public final class ConfigConstants { @Deprecated public static final String FLINK_JVM_OPTIONS = "env.java.opts"; + public static final String FLINK_DETACHED_JOB_SUBMISSION = "flink.detached.job.submission"; + // --------------------------- High Availability -------------------------- /** @deprecated Deprecated in favour of {@link HighAvailabilityOptions#HA_MODE} */ @@ -1992,6 +1994,9 @@ public final class ConfigConstants { @Deprecated public static final int DEFAULT_METRICS_LATENCY_HISTORY_SIZE = 128; + // ----------------------------- Misc ---------------------------- + public static final boolean DEFAULT_FLINK_DETACHED_JOB_SUBMISSION = true; + // ----------------------------- Environment Variables ---------------------------- /** The environment variable name which contains the location of the configuration directory. */