This is an automated email from the ASF dual-hosted git repository. hxd pushed a commit to branch comment_cluster_new in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5da1b87fcda763fe8c4d8a0f110a224f553bc8fa Author: xiangdong huang <[email protected]> AuthorDate: Fri Nov 13 11:10:56 2020 +0800 add comment for startup --- cluster/src/assembly/resources/sbin/start-node.sh | 2 +- .../src/main/java/org/apache/iotdb/cluster/ClusterMain.java | 11 ++++++++++- 2 files changed, 11 insertions(+), 2 deletions(-) diff --git a/cluster/src/assembly/resources/sbin/start-node.sh b/cluster/src/assembly/resources/sbin/start-node.sh index bba5b17..f8ff515 100755 --- a/cluster/src/assembly/resources/sbin/start-node.sh +++ b/cluster/src/assembly/resources/sbin/start-node.sh @@ -20,7 +20,7 @@ echo --------------------- -echo Starting IoTDB +echo "Starting IoTDB (Cluster Mode)" echo --------------------- if [ -z "${IOTDB_HOME}" ]; then diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/ClusterMain.java b/cluster/src/main/java/org/apache/iotdb/cluster/ClusterMain.java index 7a43a8b..b382242 100644 --- a/cluster/src/main/java/org/apache/iotdb/cluster/ClusterMain.java +++ b/cluster/src/main/java/org/apache/iotdb/cluster/ClusterMain.java @@ -64,7 +64,14 @@ public class ClusterMain { public static void main(String[] args) { if (args.length < 1) { - logger.error("Usage: <start mode>"); + logger.error("Usage: <-s|-a|-r> [-internal_meta_port <internal meta port>] " + + "[-internal_data_port <internal data port>] " + + "[-cluster_rpc_port <cluster rpc port>] " + + "[-seed_nodes <node1:meta_port:data_port:cluster_rpc_port," + + "node2:meta_port:data_port:cluster_rpc_port," + + "...,noden:meta_port:data_port:cluster_rpc_port,>] " + + "[-sc] " + + "[-rpc_port <rpc port>]"); return; } String mode = args[0]; @@ -158,10 +165,12 @@ public class ClusterMain { String[] clusterParams; String[] serverParams = null; for (index = 0; index < args.length; index++) { + //find where -sc is if (SERVER_CONF_SEPARATOR.equals(args[index])) { break; } } + //parameters from 0 to "-sc" are for clusters clusterParams = Arrays.copyOfRange(args, 0, index); if (index < args.length) {
