[flink] branch release-1.10 updated: [FLINK-15195][kubernetes] Remove unused KubernetesConfigOptionsInternal.ENTRY_POINT_CLASS_ARGS

[kkloudas]

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

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


The following commit(s) were added to refs/heads/release-1.10 by this push:
     new c1e4180  [FLINK-15195][kubernetes] Remove unused 
KubernetesConfigOptionsInternal.ENTRY_POINT_CLASS_ARGS
c1e4180 is described below

commit c1e4180efb675a15d2c362970d38500c0e5214d8
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Wed Dec 11 13:18:02 2019 +0100

    [FLINK-15195][kubernetes] Remove unused 
KubernetesConfigOptionsInternal.ENTRY_POINT_CLASS_ARGS
---
 .../kubernetes/configuration/KubernetesConfigOptionsInternal.java   | 6 ------
 .../kubeclient/decorators/FlinkMasterDeploymentDecorator.java       | 3 +--
 2 files changed, 1 insertion(+), 8 deletions(-)

diff --git 
a/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptionsInternal.java
 
b/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptionsInternal.java
index af10018..ac04cae 100644
--- 
a/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptionsInternal.java
+++ 
b/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptionsInternal.java
@@ -40,12 +40,6 @@ public class KubernetesConfigOptionsInternal {
                .noDefaultValue()
                .withDescription("The entrypoint class for jobmanager. It will 
be set in kubernetesClusterDescriptor.");
 
-       public static final ConfigOption<String> ENTRY_POINT_CLASS_ARGS = 
ConfigOptions
-               .key("kubernetes.internal.jobmanager.entrypoint.class.args")
-               .stringType()
-               .noDefaultValue()
-               .withDescription("The args of entrypoint class for jobmanager. 
It will be set in FlinkKubernetesCustomCli.");
-
        /** This class is not meant to be instantiated. */
        private KubernetesConfigOptionsInternal() {}
 }
diff --git 
a/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/FlinkMasterDeploymentDecorator.java
 
b/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/FlinkMasterDeploymentDecorator.java
index cb1e065..996359e 100644
--- 
a/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/FlinkMasterDeploymentDecorator.java
+++ 
b/flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/FlinkMasterDeploymentDecorator.java
@@ -109,7 +109,6 @@ public class FlinkMasterDeploymentDecorator extends 
Decorator<Deployment, Kubern
                        int blobServerPort) {
                final String flinkConfDirInPod = 
flinkConfig.getString(KubernetesConfigOptions.FLINK_CONF_DIR);
                final String logDirInPod = 
flinkConfig.getString(KubernetesConfigOptions.FLINK_LOG_DIR);
-               final String mainClassArgs = 
flinkConfig.getString(KubernetesConfigOptionsInternal.ENTRY_POINT_CLASS_ARGS);
                final String startCommand = 
KubernetesUtils.getJobManagerStartCommand(
                        flinkConfig,
                        clusterSpecification.getMasterMemoryMB(),
@@ -118,7 +117,7 @@ public class FlinkMasterDeploymentDecorator extends 
Decorator<Deployment, Kubern
                        hasLogback,
                        hasLog4j,
                        mainClass,
-                       mainClassArgs);
+                       null);
 
                final ResourceRequirements requirements = 
KubernetesUtils.getResourceRequirements(
                        clusterSpecification.getMasterMemoryMB(),