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 2019/11/12 07:58:45 UTC
[flink] 05/24: [FLINK-XXXXX] Add the internal IS_PYTHON method
This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a commit to branch executors
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 892a2ac785dc15ede49ba2198720aa423544f1af
Author: Kostas Kloudas <kk...@gmail.com>
AuthorDate: Mon Nov 4 15:00:34 2019 +0100
[FLINK-XXXXX] Add the internal IS_PYTHON method
---
.../org/apache/flink/client/cli/ExecutionConfigAccessor.java | 5 +++++
.../java/org/apache/flink/configuration/PipelineOptions.java | 11 +++++++++++
2 files changed, 16 insertions(+)
diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java b/flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java
index c7f8e55..5bb524d 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java
@@ -65,6 +65,7 @@ public class ExecutionConfigAccessor {
configuration.setInteger(CoreOptions.DEFAULT_PARALLELISM, options.getParallelism());
}
+ configuration.setBoolean(PipelineOptions.Internal.IS_PYTHON, options.isPython());
configuration.setBoolean(ExecutionOptions.ATTACHED, !options.getDetachedMode());
configuration.setBoolean(ExecutionOptions.SHUTDOWN_IF_ATTACHED, options.isShutdownOnAttachedExit());
@@ -128,4 +129,8 @@ public class ExecutionConfigAccessor {
public boolean isShutdownOnAttachedExit() {
return configuration.getBoolean(ExecutionOptions.SHUTDOWN_IF_ATTACHED);
}
+
+ public boolean isPython() {
+ return configuration.getBoolean(PipelineOptions.Internal.IS_PYTHON);
+ }
}
diff --git a/flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java b/flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java
index 6b2c21d..39fcc06 100644
--- a/flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java
+++ b/flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java
@@ -50,4 +50,15 @@ public class PipelineOptions {
.asList()
.noDefaultValue()
.withDescription("A semicolon-separated list of the classpaths to package with the job jars to be sent to the cluster. These have to be valid URLs.");
+
+ /**
+ * Configuration options that are **NOT** supposed to be set by the user but by the system.
+ */
+ public static class Internal {
+
+ public static final ConfigOption<Boolean> IS_PYTHON =
+ key("$internal.pipeline.python")
+ .booleanType().defaultValue(false)
+ .withDescription("Indicates if the pipeline is written in Python.");
+ }
}