[
https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 Collection<ExecutionMode[]> executionModes(){
+ Collection<ExecutionMode[]> c = new
ArrayList<ExecutionMode[]>(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);
+
+ DataSet<Integer> 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)
