[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14392353#comment-14392353 ] ASF GitHub Bot commented on FLINK-1589: --- Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/427 Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14392294#comment-14392294 ] ASF GitHub Bot commented on FLINK-1589: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/427#issuecomment-88794279 I'm merging this PR Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390468#comment-14390468 ] ASF GitHub Bot commented on FLINK-1589: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/427#issuecomment-88453493 If there are no objections, I'm going to merge the PR in the next 24 hours. Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390481#comment-14390481
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r27564491
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java ---
@@ -103,6 +110,9 @@ public void start() throws Exception {
// create the embedded runtime
Configuration configuration =
getConfiguration(this);
+ if(this.configuration != null) {
+
configuration.addAll(this.configuration);
+ }
--- End diff --
Wouldn't it be better to move the null check to the constructor and create
the default `Configuration` there via a call to `getConfiguration`?
Add option to pass Configuration to LocalExecutor
-
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type: New Feature
Reporter: Robert Metzger
Assignee: Robert Metzger
Right now its not possible for users to pass custom configuration values to
Flink when running it from within an IDE.
It would be very convenient to be able to create a local execution
environment that allows passing configuration files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390493#comment-14390493
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r27566199
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java ---
@@ -103,6 +110,9 @@ public void start() throws Exception {
// create the embedded runtime
Configuration configuration =
getConfiguration(this);
+ if(this.configuration != null) {
+
configuration.addAll(this.configuration);
+ }
--- End diff --
+1, I would rename getConfiguration to createConfiguration as well
Add option to pass Configuration to LocalExecutor
-
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type: New Feature
Reporter: Robert Metzger
Assignee: Robert Metzger
Right now its not possible for users to pass custom configuration values to
Flink when running it from within an IDE.
It would be very convenient to be able to create a local execution
environment that allows passing configuration files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390482#comment-14390482
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r27564493
--- Diff:
flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java ---
@@ -70,6 +72,11 @@ public LocalExecutor() {
}
}
+ public LocalExecutor(Configuration conf) {
+ super();
+ this.configuration = conf;
+ }
--- End diff --
Should `super()` not be actually `this()`?
Add option to pass Configuration to LocalExecutor
-
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type: New Feature
Reporter: Robert Metzger
Assignee: Robert Metzger
Right now its not possible for users to pass custom configuration values to
Flink when running it from within an IDE.
It would be very convenient to be able to create a local execution
environment that allows passing configuration files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390487#comment-14390487 ] ASF GitHub Bot commented on FLINK-1589: --- Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/427#issuecomment-88462555 Looks good. It is possible to add a more Unit-Test style test, rather than an Integration test case (starting a full mini cluster) ? Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390486#comment-14390486
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r27564611
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/LocalEnvironment.java ---
@@ -32,6 +33,7 @@
* machine.
*/
public class LocalEnvironment extends ExecutionEnvironment {
+ private Configuration configuration = null;
--- End diff --
The `= null` initializations are unnecessary.
Add option to pass Configuration to LocalExecutor
-
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type: New Feature
Reporter: Robert Metzger
Assignee: Robert Metzger
Right now its not possible for users to pass custom configuration values to
Flink when running it from within an IDE.
It would be very convenient to be able to create a local execution
environment that allows passing configuration files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390495#comment-14390495
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r27566259
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -1058,6 +1059,20 @@ public static LocalEnvironment
createLocalEnvironment(int parallelism) {
lee.setParallelism(parallelism);
return lee;
}
+
+ /**
+* Creates a {@link LocalEnvironment}. The local execution environment
will run the program in a
+* multi-threaded fashion in the same JVM as the environment was
created in. It will use the
+* degree of parallelism specified in the parameter.
--- End diff --
degree of parllelism has been renamed recently
Add option to pass Configuration to LocalExecutor
-
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type: New Feature
Reporter: Robert Metzger
Assignee: Robert Metzger
Right now its not possible for users to pass custom configuration values to
Flink when running it from within an IDE.
It would be very convenient to be able to create a local execution
environment that allows passing configuration files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390506#comment-14390506 ] ASF GitHub Bot commented on FLINK-1589: --- Github user uce commented on the pull request: https://github.com/apache/flink/pull/427#issuecomment-88473959 Looks good. - Can you add missing `@Override` tags to `executePlan` and `getOptimizerPlanAsJSON` while editing the file? - If you only want to ensure that the respective Configuration values are set, we could indeed just get the configuration object and check that the respective values keys are set as expected. Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390556#comment-14390556
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r27569381
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java ---
@@ -1058,6 +1059,20 @@ public static LocalEnvironment
createLocalEnvironment(int parallelism) {
lee.setParallelism(parallelism);
return lee;
}
+
+ /**
+* Creates a {@link LocalEnvironment}. The local execution environment
will run the program in a
+* multi-threaded fashion in the same JVM as the environment was
created in. It will use the
+* degree of parallelism specified in the parameter.
--- End diff --
+1 please change it to parallelism :)
Add option to pass Configuration to LocalExecutor
-
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type: New Feature
Reporter: Robert Metzger
Assignee: Robert Metzger
Right now its not possible for users to pass custom configuration values to
Flink when running it from within an IDE.
It would be very convenient to be able to create a local execution
environment that allows passing configuration files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14390938#comment-14390938 ] ASF GitHub Bot commented on FLINK-1589: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/427#issuecomment-88544395 It is possible to add a more Unit-Test style test, rather than an Integration test case (starting a full mini cluster) ? I've chosen this test strategy to be 100% sure that values passed by the user really end up in the system in the end. I just checked the time between the first and the last log message, its 643 milliseconds. I think that is okay. Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14384021#comment-14384021 ] ASF GitHub Bot commented on FLINK-1589: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/427#issuecomment-86979441 I've updated the PR. It is now ready for review again. Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14333259#comment-14333259
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r25159356
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ExecutionEnvironmentITCase.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * License); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.test.javaApiOperators;
+
+import org.apache.flink.api.java.DataSet;
+import org.apache.flink.api.java.ExecutionEnvironment;
+import org.apache.flink.configuration.ConfigConstants;
+import org.apache.flink.configuration.Configuration;
+import org.apache.flink.test.javaApiOperators.util.CollectionDataSets;
+import org.apache.flink.test.util.MultipleProgramsTestBase;
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+
+import java.util.ArrayList;
+import java.util.Collection;
+
+
+@RunWith(Parameterized.class)
+public class ExecutionEnvironmentITCase extends MultipleProgramsTestBase {
+
+
+ public ExecutionEnvironmentITCase(ExecutionMode mode) {
+ super(mode);
+ }
+
+ @Parameterized.Parameters(name = Execution mode = {0})
+ public static CollectionExecutionMode[] executionModes(){
+ CollectionExecutionMode[] c = new
ArrayListExecutionMode[](1);
+ c.add(new ExecutionMode[] {ExecutionMode.CLUSTER});
+ return c;
+ }
+
+
+ @Test
+ public void testLocalEnvironmentWithConfig() throws Exception {
+ IllegalArgumentException e = null;
+ try {
+ Configuration conf = new Configuration();
+
conf.setBoolean(ConfigConstants.FILESYSTEM_DEFAULT_OVERWRITE_KEY, true);
+
conf.setString(ConfigConstants.TASK_MANAGER_TMP_DIR_KEY,
/tmp/thelikelyhoodthatthisdirectoryexisitsisreallylow);
+ conf.setInteger(ConfigConstants.AKKA_ASK_TIMEOUT, 3);
+ final ExecutionEnvironment env =
ExecutionEnvironment.createLocalEnvironment(conf);
+
+ DataSetInteger ds =
CollectionDataSets.getIntegerDataSet(env);
+ ds.writeAsText(null);
+ env.execute();
+ } catch(IllegalArgumentException iae) {
--- End diff --
Yeah .. Some stuff is messed up in the test.
So right now the `ds.writeAsText(null);` is causing he
`IllegalArgumentException`, but my intention was to get the
`IllegalArgumentException` from the lower layers of the systems, namely the
Akka utils complaining about the incorrect ask timeout.
I'll follow @tillrohrmann's suggestion to implement the test differently.
Add option to pass Configuration to LocalExecutor
-
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type: New Feature
Reporter: Robert Metzger
Assignee: Robert Metzger
Right now its not possible for users to pass custom configuration values to
Flink when running it from within an IDE.
It would be very convenient to be able to create a local execution
environment that allows passing configuration files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=1414#comment-1414 ] ASF GitHub Bot commented on FLINK-1589: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/427#issuecomment-75542199 @tillrohrmann: Thank you for the good feedback! I'll continue working on this once https://github.com/apache/flink/pull/410 is merged to master. Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328841#comment-14328841 ] ASF GitHub Bot commented on FLINK-1589: --- GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/427 [FLINK-1589] Add option to pass configuration to LocalExecutor Please review the changes. I'll add a testcase and update the documentation later today. You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink flink1589 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/427.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #427 commit b75b4c285f4810faa5d02d638b61dc7b8e125c8d Author: Robert Metzger rmetz...@apache.org Date: 2015-02-20T11:40:41Z [FLINK-1589] Add option to pass configuration to LocalExecutor Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14328963#comment-14328963 ] ASF GitHub Bot commented on FLINK-1589: --- Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/427#issuecomment-75244751 I've added documentation and tests to the change. Lets see if travis gives us a green light. Add option to pass Configuration to LocalExecutor - Key: FLINK-1589 URL: https://issues.apache.org/jira/browse/FLINK-1589 Project: Flink Issue Type: New Feature Reporter: Robert Metzger Assignee: Robert Metzger Right now its not possible for users to pass custom configuration values to Flink when running it from within an IDE. It would be very convenient to be able to create a local execution environment that allows passing configuration files. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329117#comment-14329117
]
ASF GitHub Bot commented on FLINK-1589:
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/427#discussion_r25080967
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/ExecutionEnvironmentITCase.java
---
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * License); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an AS IS BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.test.javaApiOperators;
+
+import org.apache.flink.api.java.DataSet;
+import org.apache.flink.api.java.ExecutionEnvironment;
+import org.apache.flink.configuration.ConfigConstants;
+import org.apache.flink.configuration.Configuration;
+import org.apache.flink.test.javaApiOperators.util.CollectionDataSets;
+import org.apache.flink.test.util.MultipleProgramsTestBase;
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+
+import java.util.ArrayList;
+import java.util.Collection;
+
+
+@RunWith(Parameterized.class)
+public class ExecutionEnvironmentITCase extends MultipleProgramsTestBase {
+
+
+ public ExecutionEnvironmentITCase(ExecutionMode mode) {
+ super(mode);
+ }
+
+ @Parameterized.Parameters(name = Execution mode = {0})
+ public static CollectionExecutionMode[] executionModes(){
+ CollectionExecutionMode[] c = new
ArrayListExecutionMode[](1);
+ c.add(new ExecutionMode[] {ExecutionMode.CLUSTER});
+ return c;
+ }
+
+
+ @Test
+ public void testLocalEnvironmentWithConfig() throws Exception {
+ IllegalArgumentException e = null;
+ try {
+ Configuration conf = new Configuration();
+
conf.setBoolean(ConfigConstants.FILESYSTEM_DEFAULT_OVERWRITE_KEY, true);
+
conf.setString(ConfigConstants.TASK_MANAGER_TMP_DIR_KEY,
/tmp/thelikelyhoodthatthisdirectoryexisitsisreallylow);
--- End diff --
Are you sure?
Add option to pass Configuration to LocalExecutor
-
Key: FLINK-1589
URL: https://issues.apache.org/jira/browse/FLINK-1589
Project: Flink
Issue Type: New Feature
Reporter: Robert Metzger
Assignee: Robert Metzger
Right now its not possible for users to pass custom configuration values to
Flink when running it from within an IDE.
It would be very convenient to be able to create a local execution
environment that allows passing configuration files.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
