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/14 09:48:19 UTC
[flink] 06/07: [FLINK-14745] Fix setting
CoreOptions.DEFAULT_PARALLELISM in ExecutionConfigAccessor
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 <kk...@gmail.com>
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());