You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hx...@apache.org on 2020/11/13 03:19:36 UTC
[iotdb] 01/02: add comment for startup
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 <sa...@gmail.com>
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) {