This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8293c2845955348882ca91beada413d52f233412 Author: Kostas Kloudas <[email protected]> AuthorDate: Wed Nov 13 15:10:18 2019 +0100 [FLINK-14745] Fix setting CoreOptions.DEFAULT_PARALLELISM in ExecutionConfigAccessor --- .../java/org/apache/flink/client/cli/ExecutionConfigAccessor.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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 ec627ac..9e570e1 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 @@ -19,6 +19,7 @@ package org.apache.flink.client.cli; import org.apache.flink.annotation.Internal; +import org.apache.flink.api.common.ExecutionConfig; import org.apache.flink.configuration.ConfigOption; import org.apache.flink.configuration.ConfigUtils; import org.apache.flink.configuration.Configuration; @@ -61,7 +62,10 @@ public class ExecutionConfigAccessor { final Configuration configuration = new Configuration(); - configuration.setInteger(CoreOptions.DEFAULT_PARALLELISM, options.getParallelism()); + if (options.getParallelism() != ExecutionConfig.PARALLELISM_DEFAULT) { + configuration.setInteger(CoreOptions.DEFAULT_PARALLELISM, options.getParallelism()); + } + configuration.setBoolean(DeploymentOptions.ATTACHED, !options.getDetachedMode()); configuration.setBoolean(DeploymentOptions.SHUTDOWN_IF_ATTACHED, options.isShutdownOnAttachedExit());
