From b37ca76cbfe5b3ede1a130736f4b39d78c980928 Mon Sep 17 00:00:00 2001 From: Johannes Date: Tue, 3 Mar 2015 16:17:47 +0100 Subject: [PATCH] [FLINK-999] Configurability of LocalExecutor Add also the global configuration to the minicluster --- .../src/main/java/org/apache/flink/client/LocalExecutor.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java b/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java index aad77cc08e18a..bf7314072ae7c 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java +++ b/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java @@ -29,6 +29,7 @@ import org.apache.flink.api.common.Program; import org.apache.flink.configuration.ConfigConstants; import org.apache.flink.configuration.Configuration; +import org.apache.flink.configuration.GlobalConfiguration; import org.apache.flink.runtime.client.JobClient; import org.apache.flink.runtime.jobgraph.JobGraph; import org.apache.flink.api.java.ExecutionEnvironment; @@ -97,6 +98,7 @@ public void start() throws Exception { // create the embedded runtime Configuration configuration = new Configuration(); + configuration.addAll(GlobalConfiguration.getConfiguration()); configuration.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, getTaskManagerNumSlots()); configuration.setBoolean(ConfigConstants.FILESYSTEM_DEFAULT_OVERWRITE_KEY, isDefaultOverwriteFiles()); // start it up