mirror of
https://github.com/wassname/ray.git
synced 2026-06-28 00:29:38 +08:00
[Java] rename config ray.redis.address to ray.address (#10772)
Resolved Conflicts:
java/test.sh
This commit is contained in:
@@ -190,7 +190,7 @@ public class RayConfig {
|
||||
}
|
||||
|
||||
// Redis configurations.
|
||||
String redisAddress = config.getString("ray.redis.address");
|
||||
String redisAddress = config.getString("ray.address");
|
||||
if (StringUtils.isNotBlank(redisAddress)) {
|
||||
setRedisAddress(redisAddress);
|
||||
} else {
|
||||
@@ -313,7 +313,7 @@ public class RayConfig {
|
||||
dynamic.put("ray.raylet.socket-name", rayletSocketName);
|
||||
dynamic.put("ray.object-store.socket-name", objectStoreSocketName);
|
||||
dynamic.put("ray.raylet.node-manager-port", nodeManagerPort);
|
||||
dynamic.put("ray.redis.address", redisAddress);
|
||||
dynamic.put("ray.address", redisAddress);
|
||||
dynamic.put("ray.job.code-search-path", codeSearchPath);
|
||||
Config toRender = ConfigFactory.parseMap(dynamic).withFallback(config);
|
||||
return toRender.root().render(ConfigRenderOptions.concise());
|
||||
|
||||
@@ -7,6 +7,10 @@ ray {
|
||||
// Basic configurations
|
||||
// ----------------------
|
||||
|
||||
// Address of the Ray cluster to connect to.
|
||||
// If not provided, a new Ray cluster will be created.
|
||||
address: ""
|
||||
|
||||
// Run mode, available options are:
|
||||
//
|
||||
// `SINGLE_PROCESS`: Ray is running in one single Java process, without Raylet backend,
|
||||
@@ -67,10 +71,6 @@ ray {
|
||||
// Redis configurations
|
||||
// ----------------------
|
||||
redis {
|
||||
// The address of the redis server to connect, in format `ip:port`.
|
||||
// If not provided, Ray processes will be started locally, including
|
||||
// Redis server, Raylet and object store.
|
||||
address: ""
|
||||
// If `redis.server` isn't provided, which port we should use to start redis server.
|
||||
// If `head-port` is not provided, it will be generated randomly.
|
||||
// head-port: 6379
|
||||
|
||||
+1
-1
@@ -57,7 +57,7 @@ case "${OSTYPE}" in
|
||||
*) echo "Can't get ip address for ${OSTYPE}"; exit 1;;
|
||||
esac
|
||||
RAY_BACKEND_LOG_LEVEL=debug ray start --head --port=6379 --redis-password=123456 --code-search-path="$PWD/bazel-bin/java/all_tests_deploy.jar"
|
||||
RAY_BACKEND_LOG_LEVEL=debug java -cp bazel-bin/java/all_tests_deploy.jar -Dray.redis.address="$ip:6379"\
|
||||
RAY_BACKEND_LOG_LEVEL=debug java -cp bazel-bin/java/all_tests_deploy.jar -Dray.address="$ip:6379"\
|
||||
-Dray.redis.password='123456' -Dray.job.code-search-path="$PWD/bazel-bin/java/all_tests_deploy.jar" io.ray.test.MultiDriverTest
|
||||
ray stop
|
||||
popd
|
||||
|
||||
@@ -136,7 +136,7 @@ public class WalkthroughDemo {
|
||||
|
||||
public static void main(String[] args) {
|
||||
// Start Ray runtime. If you're connecting to an existing cluster, you can set
|
||||
// the `-Dray.redis.address=<cluster-address>` java system property.
|
||||
// the `-Dray.address=<cluster-address>` java system property.
|
||||
Ray.init();
|
||||
|
||||
demoTasks();
|
||||
|
||||
@@ -92,7 +92,7 @@ public abstract class BaseMultiLanguageTest {
|
||||
|
||||
// Connect to the cluster.
|
||||
Assert.assertFalse(Ray.isInitialized());
|
||||
System.setProperty("ray.redis.address", "127.0.0.1:6379");
|
||||
System.setProperty("ray.address", "127.0.0.1:6379");
|
||||
System.setProperty("ray.object-store.socket-name", PLASMA_STORE_SOCKET_NAME);
|
||||
System.setProperty("ray.raylet.socket-name", RAYLET_SOCKET_NAME);
|
||||
System.setProperty("ray.raylet.node-manager-port", nodeManagerPort);
|
||||
@@ -110,7 +110,7 @@ public abstract class BaseMultiLanguageTest {
|
||||
public void tearDown() {
|
||||
// Disconnect to the cluster.
|
||||
Ray.shutdown();
|
||||
System.clearProperty("ray.redis.address");
|
||||
System.clearProperty("ray.address");
|
||||
System.clearProperty("ray.object-store.socket-name");
|
||||
System.clearProperty("ray.raylet.socket-name");
|
||||
System.clearProperty("ray.raylet.node-manager-port");
|
||||
|
||||
@@ -119,7 +119,7 @@ public class MultiDriverTest extends BaseTest {
|
||||
"java",
|
||||
"-cp",
|
||||
System.getProperty("java.class.path"),
|
||||
"-Dray.redis.address=" + rayConfig.getRedisAddress(),
|
||||
"-Dray.address=" + rayConfig.getRedisAddress(),
|
||||
"-Dray.object-store.socket-name=" + rayConfig.objectStoreSocketName,
|
||||
"-Dray.raylet.socket-name=" + rayConfig.rayletSocketName,
|
||||
"-Dray.raylet.node-manager-port=" + String.valueOf(rayConfig.getNodeManagerPort()),
|
||||
|
||||
@@ -59,7 +59,7 @@ public class NamedActorTest extends BaseTest {
|
||||
"java",
|
||||
"-cp",
|
||||
System.getProperty("java.class.path"),
|
||||
"-Dray.redis.address=" + rayConfig.getRedisAddress(),
|
||||
"-Dray.address=" + rayConfig.getRedisAddress(),
|
||||
"-Dray.object-store.socket-name=" + rayConfig.objectStoreSocketName,
|
||||
"-Dray.raylet.socket-name=" + rayConfig.rayletSocketName,
|
||||
"-Dray.raylet.node-manager-port=" + rayConfig.getNodeManagerPort(),
|
||||
|
||||
Reference in New Issue
Block a user