[FLINK-3776] Flink Scala shell does not allow to set configuration fo…

…r local execution This closes apache#1945
vpernin · May 13, 2016 · 099fdfa · 099fdfa
1 parent 3c90d36
commit 099fdfa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala b/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
@@ -141,7 +141,7 @@ object FlinkShell {
   ): (String, Int, Option[Either[FlinkMiniCluster, AbstractFlinkYarnCluster]]) = {
     config.executionMode match {
       case ExecutionMode.LOCAL => // Local mode
-        val config = new Configuration()
+        val config = GlobalConfiguration.getConfiguration()
         config.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, 0)
 
         val miniCluster = new LocalFlinkMiniCluster(config, false)