diff --git a/ogm/tugraph-db-ogm-test/src/main/java/test/TestBase.java b/ogm/tugraph-db-ogm-test/src/main/java/test/TestBase.java index 3c953cf..ddeb1bb 100644 --- a/ogm/tugraph-db-ogm-test/src/main/java/test/TestBase.java +++ b/ogm/tugraph-db-ogm-test/src/main/java/test/TestBase.java @@ -338,7 +338,7 @@ public static void haClientTest() throws Exception { log.info("-------------------------starting follower-------------------------"); driver.close(); Thread.sleep(1000 * 7); - executive("cd ha2 && ./lgraph_server --host " + host + " --port 27073 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29093 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d start"); + executive("cd ha2 && ./lgraph_server --host " + host + " --port 27073 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29093 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d restart"); Thread.sleep(1000 * 13); driver = startHaClient("29092"); Thread.sleep(1000 * 7); @@ -361,7 +361,7 @@ public static void haClientTest() throws Exception { log.info("-------------------------starting leader-------------------------"); driver.close(); Thread.sleep(1000 * 7); - executive("cd ha1 && ./lgraph_server --host " + host + " --port 27072 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29092 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d start"); + executive("cd ha1 && ./lgraph_server --host " + host + " --port 27072 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29092 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d restart"); Thread.sleep(1000 * 13); driver = startHaClient("29093"); Thread.sleep(1000 * 7); diff --git a/rpc-client-test/src/main/java/com/antgroup/tugraph/TuGraphDbHaRpcClientTestCase.java b/rpc-client-test/src/main/java/com/antgroup/tugraph/TuGraphDbHaRpcClientTestCase.java index 87fa4da..13ff2e3 100644 --- a/rpc-client-test/src/main/java/com/antgroup/tugraph/TuGraphDbHaRpcClientTestCase.java +++ b/rpc-client-test/src/main/java/com/antgroup/tugraph/TuGraphDbHaRpcClientTestCase.java @@ -322,7 +322,7 @@ public static void haClientTest() throws Exception { log.info("-------------------------starting follower-------------------------"); client.logout(); Thread.sleep(1000 * 7); - executive("cd ha2 && ./lgraph_server --host " + host + " --port 27073 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29093 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d start"); + executive("cd ha2 && ./lgraph_server --host " + host + " --port 27073 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29093 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d restart"); Thread.sleep(1000 * 13); client = startHaClient("29092"); Thread.sleep(1000 * 7); @@ -348,7 +348,7 @@ public static void haClientTest() throws Exception { log.info("-------------------------starting leader-------------------------"); client.logout(); Thread.sleep(1000 * 7); - executive("cd ha1 && ./lgraph_server --host " + host + " --port 27072 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29092 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d start"); + executive("cd ha1 && ./lgraph_server --host " + host + " --port 27072 --enable_rpc true --enable_ha true --ha_node_offline_ms 5000 --ha_node_remove_ms 10000 --rpc_port 29092 --directory ./db --log_dir ./log --ha_conf " + host + ":29092," + host + ":29093," + host + ":29094 -c lgraph_ha.json -d restart"); Thread.sleep(1000 * 13); client = startHaClient("29093"); Thread.sleep(1000 * 7);