提交 4b8f2882 编写于 作者: M Maximilian Michels

[cleanup] remove unused code

- remove unused utility testing function
- remove leftover FLINK_CONF_DIR jvm property

This closes #2325
上级 873d6cd1
......@@ -1058,8 +1058,7 @@ public class CliFrontend {
// --------------------------------------------------------------------------------------------
public static String getConfigurationDirectoryFromEnv() {
String envLocation = System.getenv(ConfigConstants.ENV_FLINK_CONF_DIR);
String location = envLocation != null ? envLocation : System.getProperty(ConfigConstants.ENV_FLINK_CONF_DIR);
String location = System.getenv(ConfigConstants.ENV_FLINK_CONF_DIR);
if (location != null) {
if (new File(location).exists()) {
......
......@@ -18,10 +18,8 @@
package org.apache.flink.api.common;
import org.apache.flink.util.SerializedValue;
import org.junit.Test;
import java.io.IOException;
import java.util.Arrays;
import java.util.List;
......@@ -66,15 +64,4 @@ public class ExecutionConfigTest {
assertEquals(parallelism, config.getParallelism());
}
/**
* Helper function to create a new ExecutionConfig for tests.
* @return A serialized ExecutionConfig
*/
public static SerializedValue<ExecutionConfig> getSerializedConfig() {
try {
return new SerializedValue<>(new ExecutionConfig());
} catch (IOException e) {
throw new RuntimeException("Couldn't create new ExecutionConfig for test.", e);
}
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册