wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-09 03:45:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

[java] customize path of ray.conf (#3100)

Browse Source 
users can add custom path of ray.config by using -Dray.config=/path/to/ray.conf
This commit is contained in:
bibabolynn
2018-10-26 13:36:34 +08:00
committed by Hao Chen
parent d3148cc3ab
commit b4614ae69a
2 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/runtime/src/main/java/org/ray/runtime/config/RayConfig.java
+12 -3
View File
@@ -7,11 +7,13 @@ import com.typesafe.config.Config;
import com.typesafe.config.ConfigException;
import com.typesafe.config.ConfigFactory;
import java.io.File;
import java.util.List;
import java.util.Map;
import org.ray.api.id.UniqueId;
import org.ray.runtime.util.NetworkUtil;
import org.ray.runtime.util.ResourceUtil;
import org.ray.runtime.util.StringUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -242,9 +244,16 @@ public class RayConfig {
*/
public static RayConfig create() {
ConfigFactory.invalidateCaches();
Config config = ConfigFactory.systemProperties()
.withFallback(ConfigFactory.load(CUSTOM_CONFIG_FILE))
.withFallback(ConfigFactory.load(DEFAULT_CONFIG_FILE));
Config config = ConfigFactory.systemProperties();
String configPath = System.getProperty("ray.config");
if (StringUtil.isNullOrEmpty(configPath)) {
LOGGER.info("Loading config from \"ray.conf\" file in classpath.");
config = config.withFallback(ConfigFactory.load(CUSTOM_CONFIG_FILE));
} else {
LOGGER.info("Loading config from " + configPath + ".");
config = config.withFallback(ConfigFactory.parseFile(new File(configPath)));
}
config = config.withFallback(ConfigFactory.load(DEFAULT_CONFIG_FILE));
return new RayConfig(config);
}