提交 3537579b 编写于 作者: Z zentol

[FLINK-4277] Fix TaskManagerConfigurationTest#testDefaultFsParameterLoading

This closes #2310
上级 6edc7f1e
......@@ -20,6 +20,7 @@ package org.apache.flink.runtime.taskmanager;
import org.apache.flink.configuration.ConfigConstants;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.configuration.GlobalConfiguration;
import org.apache.flink.configuration.IllegalConfigurationException;
import org.apache.flink.core.fs.FileSystem;
import org.apache.flink.core.testutils.CommonTestUtils;
......@@ -110,7 +111,7 @@ public class TaskManagerConfigurationTest {
@Test
public void testDefaultFsParameterLoading() {
final File tmpDir = getTmpDir();
final File confFile = new File(tmpDir, UUID.randomUUID().toString() + ".yaml");
final File confFile = new File(tmpDir, GlobalConfiguration.FLINK_CONF_FILENAME);
try {
final URI defaultFS = new URI("otherFS", null, "localhost", 1234, null, null, null);
......@@ -119,9 +120,7 @@ public class TaskManagerConfigurationTest {
pw1.println("fs.default-scheme: "+ defaultFS);
pw1.close();
String filepath = confFile.getAbsolutePath();
String[] args = new String[]{"--configDir:"+filepath};
String[] args = new String[]{"--configDir:" + tmpDir};
TaskManager.parseArgsAndLoadConfig(args);
Field f = FileSystem.class.getDeclaredField("defaultScheme");
......@@ -129,10 +128,8 @@ public class TaskManagerConfigurationTest {
URI scheme = (URI) f.get(null);
assertEquals("Default Filesystem Scheme not configured.", scheme, defaultFS);
} catch (FileNotFoundException e) {
fail(e.getMessage());
} catch (Exception e) {
e.printStackTrace();
fail(e.getMessage());
} finally {
confFile.delete();
tmpDir.delete();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册