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());
 

Reply via email to