[ https://issues.apache.org/jira/browse/FLINK-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14333164#comment-14333164 ]
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_r25152294 --- 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"); --- End diff -- To be on the safe side, we used in other tests a temp directory (specially created) where we removed the write permissions for the user (and the in finally re-grant them in order to cleanly remove the directory) > 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)