You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2022/12/28 05:10:38 UTC
[iotdb] 01/01: change default port
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch beyyes/change_port
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit fa4eecd401fa7be81fdb9cd344faccc3a142ff1c
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Wed Dec 28 13:10:16 2022 +0800
change default port
---
.../resources/conf/iotdb-confignode.properties | 8 +--
.../assembly/resources/sbin/start-confignode.bat | 4 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 6 +--
.../request/ConfigPhysicalPlanSerDeTest.java | 56 ++++++++++-----------
.../load/balancer/router/RegionRouteMapTest.java | 8 +--
.../router/priority/GreedyPriorityTest.java | 8 +--
.../priority/LeaderPriorityBalancerTest.java | 16 +++---
.../confignode/persistence/PartitionInfoTest.java | 8 +--
.../impl/CreateRegionGroupsProcedureTest.java | 16 +++---
.../impl/node/AddConfigNodeProcedureTest.java | 2 +-
.../impl/node/RemoveConfigNodeProcedureTest.java | 2 +-
.../confignode1conf/iotdb-confignode.properties | 6 +--
.../confignode2conf/iotdb-confignode.properties | 6 +--
.../confignode3conf/iotdb-confignode.properties | 6 +--
docker/ReadMe.md | 6 +--
.../DockerCompose/docker-compose-cluster-1c2d.yml | 6 +--
.../DockerCompose/docker-compose-cluster-3c3d.yml | 16 +++---
.../DockerCompose/docker-compose-host-3c3d.yml | 16 +++---
.../DockerCompose/docker-compose-standalone.yml | 4 +-
docker/src/main/Dockerfile-0.12.6-cluster | 6 +--
docker/src/main/Dockerfile-0.13.0-cluster | 6 +--
docker/src/main/Dockerfile-1.0.0-confignode | 4 +-
docker/src/main/Dockerfile-1.0.0-datanode | 4 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 38 +++++++-------
docs/UserGuide/Cluster/Cluster-Setup.md | 36 +++++++-------
.../Edge-Cloud-Collaboration/Sync-Tool.md | 8 +--
.../Operators-Functions/Frequency-Domain.md | 2 +-
docs/UserGuide/QuickStart/ClusterQuickStart.md | 58 +++++++++++-----------
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 26 +++++-----
.../Reference/ConfigNode-Config-Manual.md | 6 +--
docs/UserGuide/Reference/DataNode-Config-Manual.md | 10 ++--
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 38 +++++++-------
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 34 ++++++-------
.../Edge-Cloud-Collaboration/Sync-Tool.md | 8 +--
docs/zh/UserGuide/QuickStart/ClusterQuickStart.md | 58 +++++++++++-----------
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 24 ++++-----
.../Reference/ConfigNode-Config-Manual.md | 6 +--
.../UserGuide/Reference/DataNode-Config-Manual.md | 10 ++--
grafana-plugin/yarn.lock | 6 +--
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 2 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 12 ++---
.../iotdb/commons/client/ClientManagerTest.java | 2 +-
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 8 +--
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 16 +++---
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 2 +-
.../resources/conf/iotdb-datanode.properties | 12 ++---
.../src/assembly/resources/sbin/start-datanode.bat | 8 +--
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 ++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 50 +++++++++----------
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 16 +++---
.../datanode1conf/iotdb-datanode.properties | 8 +--
.../datanode2conf/iotdb-datanode.properties | 8 +--
.../datanode3conf/iotdb-datanode.properties | 2 +-
.../read/filter/IExpressionOptimizerTest.java | 14 +++---
55 files changed, 380 insertions(+), 380 deletions(-)
diff --git a/confignode/src/assembly/resources/conf/iotdb-confignode.properties b/confignode/src/assembly/resources/conf/iotdb-confignode.properties
index eed5d144b5..932864ba58 100644
--- a/confignode/src/assembly/resources/conf/iotdb-confignode.properties
+++ b/confignode/src/assembly/resources/conf/iotdb-confignode.properties
@@ -28,11 +28,11 @@ cn_internal_address=127.0.0.1
# Used for RPC communication inside cluster.
# Datatype: int
-cn_internal_port=22277
+cn_internal_port=10710
# Used for consensus communication among ConfigNodes inside cluster.
# Datatype: int
-cn_consensus_port=22278
+cn_consensus_port=10720
####################
### Target Config Nodes
@@ -40,9 +40,9 @@ cn_consensus_port=22278
# For the first ConfigNode to start, cn_target_config_node_list points to its own cn_internal_address:cn_internal_port.
# For other ConfigNodes that to join the cluster, target_config_node_list points to any running ConfigNode's cn_internal_address:cn_internal_port.
-# Format: address:port(,address:port)* e.g. 127.0.0.1:22277,127.0.0.1:22279
+# Format: address:port(,address:port)* e.g. 127.0.0.1:10710,127.0.0.1:10711
# Datatype: String
-cn_target_config_node_list=127.0.0.1:22277
+cn_target_config_node_list=127.0.0.1:10710
####################
### Directory configuration
diff --git a/confignode/src/assembly/resources/sbin/start-confignode.bat b/confignode/src/assembly/resources/sbin/start-confignode.bat
index 4ba762aedf..21c19ca611 100644
--- a/confignode/src/assembly/resources/sbin/start-confignode.bat
+++ b/confignode/src/assembly/resources/sbin/start-confignode.bat
@@ -99,8 +99,8 @@ IF EXIST "%CONFIGNODE_CONF%\iotdb-confignode.properties" (
)
) ELSE (
echo "Can't find iotdb-confignode.properties, check the default ports"
- set cn_internal_port=22277
- set cn_consensus_port=22278
+ set cn_internal_port=10710
+ set cn_consensus_port=10720
)
echo Check whether the ports are occupied....
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java b/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
index 8e6b354534..94e906a9ad 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
@@ -41,13 +41,13 @@ public class ConfigNodeConfig {
private String internalAddress = "127.0.0.1";
/** used for communication between data node and config node */
- private int internalPort = 22277;
+ private int internalPort = 10710;
/** used for communication between config node and config node */
- private int consensusPort = 22278;
+ private int consensusPort = 10720;
/** Used for connecting to the ConfigNodeGroup */
- private TEndPoint targetConfigNode = new TEndPoint("127.0.0.1", 22277);
+ private TEndPoint targetConfigNode = new TEndPoint("127.0.0.1", 10710);
// TODO: Read from iotdb-confignode.properties
private int configNodeRegionId = 0;
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
index 5dc331e1cc..978d81843c 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
@@ -148,10 +148,10 @@ public class ConfigPhysicalPlanSerDeTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(1);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
TDataNodeConfiguration dataNodeConfiguration = new TDataNodeConfiguration();
dataNodeConfiguration.setLocation(dataNodeLocation);
@@ -168,10 +168,10 @@ public class ConfigPhysicalPlanSerDeTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(1);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
UpdateDataNodePlan plan0 = new UpdateDataNodePlan(dataNodeLocation);
UpdateDataNodePlan plan1 =
@@ -280,10 +280,10 @@ public class ConfigPhysicalPlanSerDeTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
CreateRegionGroupsPlan req0 = new CreateRegionGroupsPlan();
TRegionReplicaSet dataRegionSet = new TRegionReplicaSet();
@@ -306,10 +306,10 @@ public class ConfigPhysicalPlanSerDeTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
TRegionReplicaSet regionReplicaSet = new TRegionReplicaSet();
regionReplicaSet.setRegionId(new TConsensusGroupId(TConsensusGroupType.DataRegion, 0));
@@ -344,10 +344,10 @@ public class ConfigPhysicalPlanSerDeTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
String storageGroup = "root.sg0";
TSeriesPartitionSlot seriesPartitionSlot = new TSeriesPartitionSlot(10);
@@ -399,10 +399,10 @@ public class ConfigPhysicalPlanSerDeTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
String storageGroup = "root.sg0";
TSeriesPartitionSlot seriesPartitionSlot = new TSeriesPartitionSlot(10);
@@ -744,10 +744,10 @@ public class ConfigPhysicalPlanSerDeTest {
TDataNodeLocation dataNodeLocation0 = new TDataNodeLocation();
dataNodeLocation0.setDataNodeId(5);
dataNodeLocation0.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation0.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation0.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation0.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation0.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation0.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation0.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation0.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation0.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
TConsensusGroupId schemaRegionGroupId = new TConsensusGroupId(SchemaRegion, 1);
TConsensusGroupId dataRegionGroupId = new TConsensusGroupId(DataRegion, 0);
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMapTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMapTest.java
index 9481802d48..986fc68637 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMapTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/RegionRouteMapTest.java
@@ -55,10 +55,10 @@ public class RegionRouteMapTest {
new TDataNodeLocation(
j,
new TEndPoint("0.0.0.0", 6667 + j),
- new TEndPoint("0.0.0.0", 9003 + j),
- new TEndPoint("0.0.0.0", 8777 + j),
- new TEndPoint("0.0.0.0", 40010 + j),
- new TEndPoint("0.0.0.0", 50010 + j)));
+ new TEndPoint("0.0.0.0", 10730 + j),
+ new TEndPoint("0.0.0.0", 10740 + j),
+ new TEndPoint("0.0.0.0", 10760 + j),
+ new TEndPoint("0.0.0.0", 10750 + j)));
}
regionLeaderMap.put(regionGroupId, i % 3);
regionPriorityMap.put(regionGroupId, regionReplicaSet);
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/GreedyPriorityTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/GreedyPriorityTest.java
index e54fab7cd3..cb617bf027 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/GreedyPriorityTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/GreedyPriorityTest.java
@@ -50,10 +50,10 @@ public class GreedyPriorityTest {
new TDataNodeLocation(
i,
new TEndPoint("0.0.0.0", 6667 + i),
- new TEndPoint("0.0.0.0", 9003 + i),
- new TEndPoint("0.0.0.0", 8777 + i),
- new TEndPoint("0.0.0.0", 40010 + i),
- new TEndPoint("0.0.0.0", 50010 + i)));
+ new TEndPoint("0.0.0.0", 10730 + i),
+ new TEndPoint("0.0.0.0", 10740 + i),
+ new TEndPoint("0.0.0.0", 10760 + i),
+ new TEndPoint("0.0.0.0", 10750 + i)));
}
/* Build nodeCacheMap */
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/LeaderPriorityBalancerTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/LeaderPriorityBalancerTest.java
index d94f45def1..a028219b08 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/LeaderPriorityBalancerTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/priority/LeaderPriorityBalancerTest.java
@@ -51,10 +51,10 @@ public class LeaderPriorityBalancerTest {
new TDataNodeLocation(
i,
new TEndPoint("0.0.0.0", 6667 + i),
- new TEndPoint("0.0.0.0", 9003 + i),
- new TEndPoint("0.0.0.0", 8777 + i),
- new TEndPoint("0.0.0.0", 40010 + i),
- new TEndPoint("0.0.0.0", 50010 + i)));
+ new TEndPoint("0.0.0.0", 10730 + i),
+ new TEndPoint("0.0.0.0", 10740 + i),
+ new TEndPoint("0.0.0.0", 10760 + i),
+ new TEndPoint("0.0.0.0", 10750 + i)));
}
// Build nodeCacheMap
@@ -126,10 +126,10 @@ public class LeaderPriorityBalancerTest {
new TDataNodeLocation(
i,
new TEndPoint("0.0.0.0", 6667 + i),
- new TEndPoint("0.0.0.0", 9003 + i),
- new TEndPoint("0.0.0.0", 8777 + i),
- new TEndPoint("0.0.0.0", 40010 + i),
- new TEndPoint("0.0.0.0", 50010 + i)));
+ new TEndPoint("0.0.0.0", 10730 + i),
+ new TEndPoint("0.0.0.0", 10740 + i),
+ new TEndPoint("0.0.0.0", 10760 + i),
+ new TEndPoint("0.0.0.0", 10750 + i)));
}
// Build TRegionReplicaSet
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/persistence/PartitionInfoTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/persistence/PartitionInfoTest.java
index 3e8f28484d..dd504686c9 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/persistence/PartitionInfoTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/persistence/PartitionInfoTest.java
@@ -247,10 +247,10 @@ public class PartitionInfoTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
TRegionReplicaSet regionReplicaSet = new TRegionReplicaSet();
regionReplicaSet.setRegionId(new TConsensusGroupId(TConsensusGroupType.DataRegion, 0));
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateRegionGroupsProcedureTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateRegionGroupsProcedureTest.java
index ee41e42cb6..0642bf6d6a 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateRegionGroupsProcedureTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateRegionGroupsProcedureTest.java
@@ -52,18 +52,18 @@ public class CreateRegionGroupsProcedureTest {
TDataNodeLocation dataNodeLocation0 = new TDataNodeLocation();
dataNodeLocation0.setDataNodeId(5);
dataNodeLocation0.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation0.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation0.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation0.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation0.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation0.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation0.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation0.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation0.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
TDataNodeLocation dataNodeLocation1 = new TDataNodeLocation();
dataNodeLocation1.setDataNodeId(6);
dataNodeLocation1.setClientRpcEndPoint(new TEndPoint("0.0.0.1", 6667));
- dataNodeLocation1.setInternalEndPoint(new TEndPoint("0.0.0.1", 9003));
- dataNodeLocation1.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.1", 8777));
- dataNodeLocation1.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.1", 40010));
- dataNodeLocation1.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.1", 50010));
+ dataNodeLocation1.setInternalEndPoint(new TEndPoint("0.0.0.1", 10730));
+ dataNodeLocation1.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.1", 10740));
+ dataNodeLocation1.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.1", 10760));
+ dataNodeLocation1.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.1", 10750));
TConsensusGroupId schemaRegionGroupId = new TConsensusGroupId(SchemaRegion, 1);
TConsensusGroupId dataRegionGroupId = new TConsensusGroupId(DataRegion, 0);
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/AddConfigNodeProcedureTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/AddConfigNodeProcedureTest.java
index 19b7bec383..e7d2b05dc8 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/AddConfigNodeProcedureTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/AddConfigNodeProcedureTest.java
@@ -37,7 +37,7 @@ public class AddConfigNodeProcedureTest {
AddConfigNodeProcedure procedure0 =
new AddConfigNodeProcedure(
new TConfigNodeLocation(
- 0, new TEndPoint("127.0.0.1", 22277), new TEndPoint("0.0.0.0", 22278)));
+ 0, new TEndPoint("127.0.0.1", 10710), new TEndPoint("0.0.0.0", 10720)));
try (PublicBAOS byteArrayOutputStream = new PublicBAOS();
DataOutputStream outputStream = new DataOutputStream(byteArrayOutputStream)) {
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveConfigNodeProcedureTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveConfigNodeProcedureTest.java
index c01b620a5a..59351867e2 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveConfigNodeProcedureTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveConfigNodeProcedureTest.java
@@ -37,7 +37,7 @@ public class RemoveConfigNodeProcedureTest {
RemoveConfigNodeProcedure procedure0 =
new RemoveConfigNodeProcedure(
new TConfigNodeLocation(
- 0, new TEndPoint("127.0.0.1", 22277), new TEndPoint("0.0.0.0", 22278)));
+ 0, new TEndPoint("127.0.0.1", 10710), new TEndPoint("0.0.0.0", 10720)));
try (PublicBAOS byteArrayOutputStream = new PublicBAOS();
DataOutputStream outputStream = new DataOutputStream(byteArrayOutputStream)) {
diff --git a/confignode/src/test/resources/confignode1conf/iotdb-confignode.properties b/confignode/src/test/resources/confignode1conf/iotdb-confignode.properties
index 3c4e761ffd..ebc0e98212 100644
--- a/confignode/src/test/resources/confignode1conf/iotdb-confignode.properties
+++ b/confignode/src/test/resources/confignode1conf/iotdb-confignode.properties
@@ -18,9 +18,9 @@
#
cn_internal_address=127.0.0.1
-cn_internal_port=22277
-cn_consensus_port=22278
-cn_target_config_node_list=127.0.0.1:22277
+cn_internal_port=10710
+cn_consensus_port=10720
+cn_target_config_node_list=127.0.0.1:10710
cn_system_dir=target/confignode1/system
cn_data_dirs=target/confignode1/data
cn_consensus_dir=target/confignode1/consensus
diff --git a/confignode/src/test/resources/confignode2conf/iotdb-confignode.properties b/confignode/src/test/resources/confignode2conf/iotdb-confignode.properties
index a0d4e4ef98..1a0ceaf8c3 100644
--- a/confignode/src/test/resources/confignode2conf/iotdb-confignode.properties
+++ b/confignode/src/test/resources/confignode2conf/iotdb-confignode.properties
@@ -18,9 +18,9 @@
#
cn_internal_address=127.0.0.1
-cn_internal_port=22279
-cn_consensus_port=22280
-cn_target_config_node_list=127.0.0.1:22277
+cn_internal_port=10711
+cn_consensus_port=10721
+cn_target_config_node_list=127.0.0.1:10710
cn_system_dir=target/confignode2/system
cn_data_dirs=target/confignode2/data
cn_consensus_dir=target/confignode2/consensus
diff --git a/confignode/src/test/resources/confignode3conf/iotdb-confignode.properties b/confignode/src/test/resources/confignode3conf/iotdb-confignode.properties
index b95a94e5d8..f2eaaa2c7a 100644
--- a/confignode/src/test/resources/confignode3conf/iotdb-confignode.properties
+++ b/confignode/src/test/resources/confignode3conf/iotdb-confignode.properties
@@ -18,9 +18,9 @@
#
cn_internal_address=127.0.0.1
-cn_internal_port=22281
-cn_consensus_port=22282
-cn_target_config_node_list=127.0.0.1:22277
+cn_internal_port=10712
+cn_consensus_port=10722
+cn_target_config_node_list=127.0.0.1:10710
cn_system_dir=target/confignode3/system
cn_data_dirs=target/confignode3/data
cn_consensus_dir=target/confignode3/consensus
diff --git a/docker/ReadMe.md b/docker/ReadMe.md
index 039f337d37..dde2b0f0b5 100644
--- a/docker/ReadMe.md
+++ b/docker/ReadMe.md
@@ -72,7 +72,7 @@ docker run -d --name iotdb -p 6667:6667 -p 31999:31999 -p 8181:8181 -p 5555:5555
```
```shell
-docker run -d --name iotdb -p 6667:6667 -p 31999:31999 -p 8181:8181 -p 5555:5555 -p 9003:9003 -p 40010:40010 apache/iotdb:<version>
+docker run -d --name iotdb -p 6667:6667 -p 31999:31999 -p 8181:8181 -p 5555:5555 -p 10730:10730 -p 10760:10760 apache/iotdb:<version>
```
Since 1.0.0, see [offical documents.](https://iotdb.apache.org/UserGuide/Master/QuickStart/WayToGetIoTDB.html)
## Port description
@@ -84,8 +84,8 @@ By default, the ports that IoTDB uses are:
* 8086: InfluxDB Protocol port
* 8181: Monitor port
* 5555: Data sync port
-* 9003: internal metadata rpc port (for cluster)
-* 40010: internal data rpc port (for cluster)
+* 10730: internal metadata rpc port (for cluster)
+* 10760: internal data rpc port (for cluster)
## How to configure docker volumes
diff --git a/docker/src/main/DockerCompose/docker-compose-cluster-1c2d.yml b/docker/src/main/DockerCompose/docker-compose-cluster-1c2d.yml
index 8653fcfd2e..21bce4786e 100644
--- a/docker/src/main/DockerCompose/docker-compose-cluster-1c2d.yml
+++ b/docker/src/main/DockerCompose/docker-compose-cluster-1c2d.yml
@@ -24,7 +24,7 @@ services:
container_name: iotdb-confignode
environment:
- cn_internal_address=iotdb-confignode
- - cn_target_config_node_list=iotdb-confignode:22277
+ - cn_target_config_node_list=iotdb-confignode:10710
volumes:
- ./data/confignode:/iotdb/data
- ./logs/confignode:/iotdb/logs
@@ -41,7 +41,7 @@ services:
environment:
- dn_rpc_address=iotdb-datanode-1
- dn_internal_address=iotdb-datanode-1
- - dn_target_config_node_list=iotdb-confignode:22277
+ - dn_target_config_node_list=iotdb-confignode:10710
volumes:
- ./data/datanode1:/iotdb/data/
- ./logs/datanode1:/iotdb/logs/
@@ -56,7 +56,7 @@ services:
environment:
- dn_rpc_address=iotdb-datanode-2
- dn_internal_address=iotdb-datanode-2
- - dn_target_config_node_list=iotdb-confignode:22277
+ - dn_target_config_node_list=iotdb-confignode:10710
volumes:
- ./data/datanode2:/iotdb/data/
- ./logs/datanode2:/iotdb/logs/
diff --git a/docker/src/main/DockerCompose/docker-compose-cluster-3c3d.yml b/docker/src/main/DockerCompose/docker-compose-cluster-3c3d.yml
index 07a61f38b1..b1b668ff58 100644
--- a/docker/src/main/DockerCompose/docker-compose-cluster-3c3d.yml
+++ b/docker/src/main/DockerCompose/docker-compose-cluster-3c3d.yml
@@ -22,11 +22,11 @@ services:
image: apache/iotdb:1.0.0-confignode
container_name: iotdb-confignode
ports:
- - "22277:22277"
- - "22278:22278"
+ - "10710:10710"
+ - "10720:10720"
environment:
- cn_internal_address=iotdb-confignode-1
- - cn_target_config_node_list=iotdb-confignode-1:22277
+ - cn_target_config_node_list=iotdb-confignode-1:10710
volumes:
- /etc/hosts:/etc/hosts:ro
- ./data/confignode:/iotdb/data
@@ -40,14 +40,14 @@ services:
container_name: iotdb-datanode
ports:
- "6667:6667"
- - "8777:8777"
- - "9003:9003"
- - "50010:50010"
- - "40010:40010"
+ - "10740:10740"
+ - "10720:10720"
+ - "10750:10750"
+ - "10760:10760"
environment:
- dn_rpc_address=iotdb-datanode-1
- dn_internal_address=iotdb-datanode-1
- - dn_target_config_node_list=iotdb-confignode-1:22277
+ - dn_target_config_node_list=iotdb-confignode-1:10710
volumes:
- /etc/hosts:/etc/hosts:ro
- ./data/datanode1:/iotdb/data/
diff --git a/docker/src/main/DockerCompose/docker-compose-host-3c3d.yml b/docker/src/main/DockerCompose/docker-compose-host-3c3d.yml
index 0de9bef89f..7903d72813 100644
--- a/docker/src/main/DockerCompose/docker-compose-host-3c3d.yml
+++ b/docker/src/main/DockerCompose/docker-compose-host-3c3d.yml
@@ -22,11 +22,11 @@ services:
image: apache/iotdb:1.0.0-confignode
container_name: iotdb-confignode
ports:
- - "22277:22277"
- - "22278:22278"
+ - "10710:10710"
+ - "10720:10720"
environment:
- cn_internal_address=iotdb-1
- - cn_target_config_node_list=iotdb-1:22277
+ - cn_target_config_node_list=iotdb-1:10710
- schema_replication_factor=3
- schema_region_consensus_protocol_class=org.apache.iotdb.consensus.ratis.RatisConsensus
- config_node_consensus_protocol_class=org.apache.iotdb.consensus.ratis.RatisConsensus
@@ -41,14 +41,14 @@ services:
container_name: iotdb-datanode
ports:
- "6667:6667"
- - "8777:8777"
- - "9003:9003"
- - "50010:50010"
- - "40010:40010"
+ - "10740:10740"
+ - "10730:10730"
+ - "10750:10750"
+ - "10760:10760"
environment:
- dn_rpc_address=iotdb-1
- dn_internal_address=iotdb-1
- - dn_target_config_node_list=iotdb-1:22277
+ - dn_target_config_node_list=iotdb-1:10710
- data_replication_factor=3
- data_region_consensus_protocol_class=org.apache.iotdb.consensus.iot.IoTConsensus
volumes:
diff --git a/docker/src/main/DockerCompose/docker-compose-standalone.yml b/docker/src/main/DockerCompose/docker-compose-standalone.yml
index 4680bbe779..bbf408470f 100644
--- a/docker/src/main/DockerCompose/docker-compose-standalone.yml
+++ b/docker/src/main/DockerCompose/docker-compose-standalone.yml
@@ -26,9 +26,9 @@ services:
- "6667:6667"
environment:
- cn_internal_address=iotdb-service
- - cn_target_config_node_list=iotdb-service:22277
+ - cn_target_config_node_list=iotdb-service:10710
- dn_rpc_address=iotdb-service
- - dn_target_config_node_list=iotdb-service:22277
+ - dn_target_config_node_list=iotdb-service:10710
volumes:
- ./data:/iotdb/data
- ./logs:/iotdb/logs
diff --git a/docker/src/main/Dockerfile-0.12.6-cluster b/docker/src/main/Dockerfile-0.12.6-cluster
index b7975dee43..0e81b4b989 100644
--- a/docker/src/main/Dockerfile-0.12.6-cluster
+++ b/docker/src/main/Dockerfile-0.12.6-cluster
@@ -32,7 +32,7 @@ RUN apt update \
&& apt purge --auto-remove -y \
&& apt clean -y \
# modify the seeds in configuration file
- && sed -i '/^seed_nodes/cseed_nodes=127.0.0.1:9003' /iotdb/conf/iotdb-cluster.properties \
+ && sed -i '/^seed_nodes/cseed_nodes=127.0.0.1:10730' /iotdb/conf/iotdb-cluster.properties \
&& sed -i '/^default_replica_num/cdefault_replica_num=1' /iotdb/conf/iotdb-cluster.properties
# rpc port
@@ -44,9 +44,9 @@ EXPOSE 5555
# monitor port
EXPOSE 8181
# internal meta port
-EXPOSE 9003
+EXPOSE 10730
# internal data port
-EXPOSE 40010
+EXPOSE 10760
VOLUME /iotdb/data
VOLUME /iotdb/logs
ENV PATH="/iotdb/sbin/:/iotdb/tools/:${PATH}"
diff --git a/docker/src/main/Dockerfile-0.13.0-cluster b/docker/src/main/Dockerfile-0.13.0-cluster
index 15600260f8..c04323a9bd 100644
--- a/docker/src/main/Dockerfile-0.13.0-cluster
+++ b/docker/src/main/Dockerfile-0.13.0-cluster
@@ -32,7 +32,7 @@ RUN apt update \
&& apt purge --auto-remove -y \
&& apt clean -y \
# modify the seeds in configuration file
- && sed -i '/^seed_nodes/cseed_nodes=127.0.0.1:9003' /iotdb/conf/iotdb-cluster.properties \
+ && sed -i '/^seed_nodes/cseed_nodes=127.0.0.1:10730' /iotdb/conf/iotdb-cluster.properties \
&& sed -i '/^default_replica_num/cdefault_replica_num=1' /iotdb/conf/iotdb-cluster.properties
# rpc port
@@ -44,9 +44,9 @@ EXPOSE 5555
# monitor port
EXPOSE 8181
# internal meta port
-EXPOSE 9003
+EXPOSE 10730
# internal data port
-EXPOSE 40010
+EXPOSE 10760
VOLUME /iotdb/data
VOLUME /iotdb/logs
ENV PATH="/iotdb/sbin/:/iotdb/tools/:${PATH}"
diff --git a/docker/src/main/Dockerfile-1.0.0-confignode b/docker/src/main/Dockerfile-1.0.0-confignode
index b324dcd287..44a30e9869 100644
--- a/docker/src/main/Dockerfile-1.0.0-confignode
+++ b/docker/src/main/Dockerfile-1.0.0-confignode
@@ -39,8 +39,8 @@ COPY DockerCompose/entrypoint.sh .
RUN chmod +x *.sh && dos2unix *.sh \
&& dos2unix ${IOTDB_HOME}/conf/*.sh
-EXPOSE 22277
-EXPOSE 22278
+EXPOSE 10710
+EXPOSE 10720
VOLUME ${IOTDB_HOME}/data
VOLUME ${IOTDB_HOME}/logs
diff --git a/docker/src/main/Dockerfile-1.0.0-datanode b/docker/src/main/Dockerfile-1.0.0-datanode
index f94d591991..c6ad20e7de 100644
--- a/docker/src/main/Dockerfile-1.0.0-datanode
+++ b/docker/src/main/Dockerfile-1.0.0-datanode
@@ -41,8 +41,8 @@ RUN chmod +x *.sh && dos2unix *.sh \
&& dos2unix ${IOTDB_HOME}/conf/*.sh
EXPOSE 6667
-EXPOSE 8777
-EXPOSE 9003
+EXPOSE 10740
+EXPOSE 10730
VOLUME $IOTDB_HOME/data
VOLUME $IOTDB_HOME/logs
diff --git a/docs/UserGuide/Cluster/Cluster-Maintenance.md b/docs/UserGuide/Cluster/Cluster-Maintenance.md
index 311f35b201..4d879add8c 100644
--- a/docs/UserGuide/Cluster/Cluster-Maintenance.md
+++ b/docs/UserGuide/Cluster/Cluster-Maintenance.md
@@ -34,9 +34,9 @@ IoTDB> show confignodes
+------+-------+---------------+------------+--------+
|NodeID| Status|InternalAddress|InternalPort| Role|
+------+-------+---------------+------------+--------+
-| 0|Running| 127.0.0.1| 22277| Leader|
-| 1|Running| 127.0.0.1| 22279|Follower|
-| 2|Running| 127.0.0.1| 22281|Follower|
+| 0|Running| 127.0.0.1| 10710| Leader|
+| 1|Running| 127.0.0.1| 10711|Follower|
+| 2|Running| 127.0.0.1| 10712|Follower|
+------+-------+---------------+------------+--------+
Total line number = 3
It costs 0.030s
@@ -110,11 +110,11 @@ IoTDB> show cluster
+------+----------+-------+---------------+------------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|
+------+----------+-------+---------------+------------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277|
-| 1|ConfigNode|Running| 127.0.0.1| 22279|
-| 2|ConfigNode|Running| 127.0.0.1| 22281|
-| 3| DataNode|Running| 127.0.0.1| 9003|
-| 4| DataNode|Running| 127.0.0.1| 9005|
+| 0|ConfigNode|Running| 127.0.0.1| 10710|
+| 1|ConfigNode|Running| 127.0.0.1| 10711|
+| 2|ConfigNode|Running| 127.0.0.1| 10712|
+| 3| DataNode|Running| 127.0.0.1| 10730|
+| 4| DataNode|Running| 127.0.0.1| 10732|
| 5| DataNode|Running| 127.0.0.1| 9007|
+------+----------+-------+---------------+------------+
Total line number = 6
@@ -127,11 +127,11 @@ IoTDB> show cluster
+------+----------+-------+---------------+------------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|
+------+----------+-------+---------------+------------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277|
-| 1|ConfigNode|Unknown| 127.0.0.1| 22279|
-| 2|ConfigNode|Running| 127.0.0.1| 22281|
-| 3| DataNode|Running| 127.0.0.1| 9003|
-| 4| DataNode|Running| 127.0.0.1| 9005|
+| 0|ConfigNode|Running| 127.0.0.1| 10710|
+| 1|ConfigNode|Unknown| 127.0.0.1| 10711|
+| 2|ConfigNode|Running| 127.0.0.1| 10712|
+| 3| DataNode|Running| 127.0.0.1| 10730|
+| 4| DataNode|Running| 127.0.0.1| 10732|
| 5| DataNode|Running| 127.0.0.1| 9007|
+------+----------+-------+---------------+------------+
Total line number = 6
@@ -149,12 +149,12 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort|RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277| 22278| | | | | |
-| 1|ConfigNode|Running| 127.0.0.1| 22279| 22280| | | | | |
-| 2|ConfigNode|Running| 127.0.0.1| 22281| 22282| | | | | |
-| 3| DataNode|Running| 127.0.0.1| 9003| | 127.0.0.1| 6667| 40010| 50010| 8777|
-| 4| DataNode|Running| 127.0.0.1| 9004| | 127.0.0.1| 6668| 40011| 50011| 8778|
-| 5| DataNode|Running| 127.0.0.1| 9005| | 127.0.0.1| 6669| 40012| 50012| 8779|
+| 0|ConfigNode|Running| 127.0.0.1| 10710| 10720| | | | | |
+| 1|ConfigNode|Running| 127.0.0.1| 10711| 10721| | | | | |
+| 2|ConfigNode|Running| 127.0.0.1| 10712| 10722| | | | | |
+| 3| DataNode|Running| 127.0.0.1| 10730| | 127.0.0.1| 6667| 10760| 10750| 10740|
+| 4| DataNode|Running| 127.0.0.1| 10731| | 127.0.0.1| 6668| 10761| 10751| 10741|
+| 5| DataNode|Running| 127.0.0.1| 10732| | 127.0.0.1| 6669| 10762| 10752| 10742|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
Total line number = 6
It costs 0.340s
diff --git a/docs/UserGuide/Cluster/Cluster-Setup.md b/docs/UserGuide/Cluster/Cluster-Setup.md
index 61e5700cde..30a7fd4098 100644
--- a/docs/UserGuide/Cluster/Cluster-Setup.md
+++ b/docs/UserGuide/Cluster/Cluster-Setup.md
@@ -31,8 +31,8 @@ This document describes how to install and start IoTDB Cluster (1.0.0).
4. Ensure that data/confignode directory has been cleared when starting ConfigNode for the first time,
and data/datanode directory has been cleared when starting DataNode for the first time
5. Turn off the firewall of the server if the entire cluster is in a trusted environment.
-6. By default, IoTDB Cluster will use ports 22277, 22278 for the ConfigNode and
-6667, 8777, 9003, 40010 and 50010 for the DataNode.
+6. By default, IoTDB Cluster will use ports 10710, 10720 for the ConfigNode and
+6667, 10740, 10730, 10760 and 10750 for the DataNode.
Please make sure those ports are not occupied, or you will modify the ports in configuration files.
# 3. Get the Installation Package
@@ -129,9 +129,9 @@ and set the following parameters based on the IP address and available port of t
| **Configuration** | **Description** | **Default** | **Usage** |
|--------------------------------|------------------------------------------------------------------------------------------------------------------------------------------|-----------------|-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|
| cn\_internal\_address | Internal rpc service address of ConfigNode | 127.0.0.1 | Set to the IPV4 address or domain name of the server |
-| cn\_internal\_port | Internal rpc service port of ConfigNode | 22277 | Set to any unoccupied port |
-| cn\_consensus\_port | ConfigNode replication consensus protocol communication port | 22278 | Set to any unoccupied port |
-| cn\_target\_config\_node\_list | ConfigNode address to which the node is connected when it is registered to the cluster. Note that Only one ConfigNode can be configured. | 127.0.0.1:22277 | For Seed-ConfigNode, set to its own cn\_internal\_address:cn\_internal\_port; For other ConfigNodes, set to other one running ConfigNode's cn\_internal\_address:cn\_internal\_port |
+| cn\_internal\_port | Internal rpc service port of ConfigNode | 10710 | Set to any unoccupied port |
+| cn\_consensus\_port | ConfigNode replication consensus protocol communication port | 10720 | Set to any unoccupied port |
+| cn\_target\_config\_node\_list | ConfigNode address to which the node is connected when it is registered to the cluster. Note that Only one ConfigNode can be configured. | 127.0.0.1:10710 | For Seed-ConfigNode, set to its own cn\_internal\_address:cn\_internal\_port; For other ConfigNodes, set to other one running ConfigNode's cn\_internal\_address:cn\_internal\_port |
**Notice: The preceding configuration parameters cannot be changed after the node is started. Ensure that all ports are not occupied. Otherwise, the Node cannot be started.**
@@ -145,11 +145,11 @@ and set the following parameters based on the IP address and available port of t
| dn\_rpc\_address | Client RPC Service address | 127.0.0.1 | Set to the IPV4 address or domain name of the server |
| dn\_rpc\_port | Client RPC Service port | 6667 | Set to any unoccupied port |
| dn\_internal\_address | Control flow address of DataNode inside cluster | 127.0.0.1 | Set to the IPV4 address or domain name of the server |
-| dn\_internal\_port | Control flow port of DataNode inside cluster | 9003 | Set to any unoccupied port |
-| dn\_mpp\_data\_exchange\_port | Data flow port of DataNode inside cluster | 8777 | Set to any unoccupied port |
-| dn\_data\_region\_consensus\_port | Data replicas communication port for consensus | 50010 | Set to any unoccupied port |
-| dn\_schema\_region\_consensus\_port | Schema replicas communication port for consensus | 40010 | Set to any unoccupied port |
-| dn\_target\_config\_node\_list | Running ConfigNode of the Cluster | 127.0.0.1:22277 | Set to any running ConfigNode's cn\_internal\_address:cn\_internal\_port. You can set multiple values, separate them with commas(",") |
+| dn\_internal\_port | Control flow port of DataNode inside cluster | 10730 | Set to any unoccupied port |
+| dn\_mpp\_data\_exchange\_port | Data flow port of DataNode inside cluster | 10740 | Set to any unoccupied port |
+| dn\_data\_region\_consensus\_port | Data replicas communication port for consensus | 10750 | Set to any unoccupied port |
+| dn\_schema\_region\_consensus\_port | Schema replicas communication port for consensus | 10760 | Set to any unoccupied port |
+| dn\_target\_config\_node\_list | Running ConfigNode of the Cluster | 127.0.0.1:10710 | Set to any running ConfigNode's cn\_internal\_address:cn\_internal\_port. You can set multiple values, separate them with commas(",") |
**Notice: The preceding configuration parameters cannot be changed after the node is started. Ensure that all ports are not occupied. Otherwise, the Node cannot be started.**
@@ -287,8 +287,8 @@ Please read the [Cli manual](https://iotdb.apache.org/UserGuide/Master/QuickStar
## 6.3 Verify Cluster
Use a 3C3D(3 ConfigNodes and 3 DataNodes) as an example.
-Assumed that the IP addresses of the 3 ConfigNodes are 192.168.1.10, 192.168.1.11 and 192.168.1.12, and the default ports 22277 and 22278 are used.
-Assumed that the IP addresses of the 3 DataNodes are 192.168.1.20, 192.168.1.21 and 192.168.1.22, and the default ports 9003, 6667, 40010, 50010 and 8777 are used.
+Assumed that the IP addresses of the 3 ConfigNodes are 192.168.1.10, 192.168.1.11 and 192.168.1.12, and the default ports 10710 and 10720 are used.
+Assumed that the IP addresses of the 3 DataNodes are 192.168.1.20, 192.168.1.21 and 192.168.1.22, and the default ports 10730, 6667, 10760, 10750 and 10740 are used.
After starting the cluster successfully according to chapter 6.1, you can run the `show cluster details` command on the Cli, and you will see the following results:
@@ -297,12 +297,12 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+------------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort| RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+------------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 192.168.1.10| 22277| 22278| | | | | |
-| 2|ConfigNode|Running| 192.168.1.11| 22277| 22278| | | | | |
-| 3|ConfigNode|Running| 192.168.1.12| 22277| 22278| | | | | |
-| 1| DataNode|Running| 192.168.1.20| 9003| |192.168.1.20| 6667| 40010| 50010| 8777|
-| 4| DataNode|Running| 192.168.1.21| 9003| |192.168.1.21| 6667| 40010| 50010| 8777|
-| 5| DataNode|Running| 192.168.1.22| 9003| |192.168.1.22| 6667| 40010| 50010| 8777|
+| 0|ConfigNode|Running| 192.168.1.10| 10710| 10720| | | | | |
+| 2|ConfigNode|Running| 192.168.1.11| 10710| 10720| | | | | |
+| 3|ConfigNode|Running| 192.168.1.12| 10710| 10720| | | | | |
+| 1| DataNode|Running| 192.168.1.20| 10730| |192.168.1.20| 6667| 10760| 10750| 10740|
+| 4| DataNode|Running| 192.168.1.21| 10730| |192.168.1.21| 6667| 10760| 10750| 10740|
+| 5| DataNode|Running| 192.168.1.22| 10730| |192.168.1.22| 6667| 10760| 10750| 10740|
+------+----------+-------+---------------+------------+-------------------+------------+-------+-----------------+-------------------+-------+
Total line number = 6
It costs 0.012s
diff --git a/docs/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md b/docs/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
index e2a0162663..2214646b59 100644
--- a/docs/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
+++ b/docs/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
@@ -358,16 +358,16 @@ It costs 0.134s
- Execute `CREATE PIPE p to demo` get message `PIPE [p] is STOP, please retry after drop it.`
- Cause by: Current Pipe already exists
- Solution: Execute `DROP PIPE p` to drop Pipe and recreate it.
-- Execute `CREATE PIPE p to demo` get message `Fail to create PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:9005)}.`
+- Execute `CREATE PIPE p to demo` get message `Fail to create PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:10732)}.`
- Cause by: There are some DataNodes with the status Running cannot be connected.
- Solution: Execute `SHOW DATANODES`, and check for unreachable DataNode networks, or wait for their status to change to Unknown and re-execute the statement.
-- Execute `START PIPE p` get message `Fail to start PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:9005)}.`
+- Execute `START PIPE p` get message `Fail to start PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:10732)}.`
- Cause by: There are some DataNodes with the status Running cannot be connected.
- Solution: Execute `SHOW DATANODES`, and check for unreachable DataNode networks, or wait for their status to change to Unknown and re-execute the statement.
-- Execute `STOP PIPE p` get message `Fail to stop PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:9005)}.`
+- Execute `STOP PIPE p` get message `Fail to stop PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:10732)}.`
- Cause by: There are some DataNodes with the status Running cannot be connected.
- Solution: Execute `SHOW DATANODES`, and check for unreachable DataNode networks, or wait for their status to change to Unknown and re-execute the statement.
-- Execute `DROP PIPE p` get message `Fail to DROP_PIPE because Fail to drop PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:9005)}. Please execute [DROP PIPE p] later to retry.`
+- Execute `DROP PIPE p` get message `Fail to DROP_PIPE because Fail to drop PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:10732)}. Please execute [DROP PIPE p] later to retry.`
- Cause by: There are some DataNodes with the status Running cannot be connected. Pipe has been deleted on some nodes and the status has been set to ***DROP***.
- Solution: Execute `SHOW DATANODES`, and check for unreachable DataNode networks, or wait for their status to change to Unknown and re-execute the statement.
- Sync.log prompts `org.apache.iotdb.commons.exception.IoTDBException: root.** already been created as database`
diff --git a/docs/UserGuide/Operators-Functions/Frequency-Domain.md b/docs/UserGuide/Operators-Functions/Frequency-Domain.md
index fd801e5667..63fdae9ca4 100644
--- a/docs/UserGuide/Operators-Functions/Frequency-Domain.md
+++ b/docs/UserGuide/Operators-Functions/Frequency-Domain.md
@@ -224,7 +224,7 @@ Output series:
|1970-01-01T08:00:01.100+08:00| -0.8485281289944873|
|1970-01-01T08:00:01.200+08:00| 0.2828427799095765|
|1970-01-01T08:00:01.300+08:00| -1.414213562373095|
-|1970-01-01T08:00:01.400+08:00| 0.42426400127697095|
+|1970-01-01T08:00:01.400+08:00| 0.42426107627697095|
|1970-01-01T08:00:01.500+08:00| -0.42426408557066786|
+-----------------------------+-------------------------------------+
```
diff --git a/docs/UserGuide/QuickStart/ClusterQuickStart.md b/docs/UserGuide/QuickStart/ClusterQuickStart.md
index 53902e43ed..2f4580ad35 100644
--- a/docs/UserGuide/QuickStart/ClusterQuickStart.md
+++ b/docs/UserGuide/QuickStart/ClusterQuickStart.md
@@ -53,8 +53,8 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort|RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277| 22278| | | | | |
-| 1| DataNode|Running| 127.0.0.1| 9003| | 127.0.0.1| 6667| 40010| 50010| 8777|
+| 0|ConfigNode|Running| 127.0.0.1| 10710| 10720| | | | | |
+| 1| DataNode|Running| 127.0.0.1| 10730| | 127.0.0.1| 6667| 10760| 10750| 10740|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
Total line number = 2
It costs 0.242s
@@ -73,9 +73,9 @@ For folder cluster1:
| **configuration item** | **value** |
|--------------------------------|-----------------|
| cn\_internal\_address | 127.0.0.1 |
-| cn\_internal\_port | 22279 |
-| cn\_consensus\_port | 22280 |
-| cn\_target\_config\_node\_list | 127.0.0.1:22277 |
+| cn\_internal\_port | 10711 |
+| cn\_consensus\_port | 10721 |
+| cn\_target\_config\_node\_list | 127.0.0.1:10710 |
+ Modify DataNode configurations:
@@ -84,11 +84,11 @@ For folder cluster1:
| dn\_rpc\_address | 127.0.0.1 |
| dn\_rpc\_port | 6668 |
| dn\_internal\_address | 127.0.0.1 |
-| dn\_internal\_port | 9004 |
-| dn\_mpp\_data\_exchange\_port | 8778 |
-| dn\_data\_region\_consensus\_port | 40011 |
-| dn\_schema\_region\_consensus\_port | 50011 |
-| dn\_target\_config\_node\_list | 127.0.0.1:22277 |
+| dn\_internal\_port | 10731 |
+| dn\_mpp\_data\_exchange\_port | 10741 |
+| dn\_data\_region\_consensus\_port | 10761 |
+| dn\_schema\_region\_consensus\_port | 10751 |
+| dn\_target\_config\_node\_list | 127.0.0.1:10710 |
For folder cluster2:
@@ -97,9 +97,9 @@ For folder cluster2:
| **configuration item** | **value** |
|--------------------------------|-----------------|
| cn\_internal\_address | 127.0.0.1 |
-| cn\_internal\_port | 22281 |
-| cn\_consensus\_port | 22282 |
-| cn\_target\_config\_node\_list | 127.0.0.1:22277 |
+| cn\_internal\_port | 10712 |
+| cn\_consensus\_port | 10722 |
+| cn\_target\_config\_node\_list | 127.0.0.1:10710 |
+ Modify DataNode configurations:
@@ -108,11 +108,11 @@ For folder cluster2:
| dn\_rpc\_address | 127.0.0.1 |
| dn\_rpc\_port | 6669 |
| dn\_internal\_address | 127.0.0.1 |
-| dn\_internal\_port | 9005 |
-| dn\_mpp\_data\_exchange\_port | 8779 |
-| dn\_data\_region\_consensus\_port | 40012 |
-| dn\_schema\_region\_consensus\_port | 50012 |
-| dn\_target\_config\_node\_list | 127.0.0.1:22277 |
+| dn\_internal\_port | 10732 |
+| dn\_mpp\_data\_exchange\_port | 10742 |
+| dn\_data\_region\_consensus\_port | 10762 |
+| dn\_schema\_region\_consensus\_port | 10752 |
+| dn\_target\_config\_node\_list | 127.0.0.1:10710 |
### 6. Expanding the Cluster
@@ -134,12 +134,12 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort|RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277| 22278| | | | | |
-| 2|ConfigNode|Running| 127.0.0.1| 22279| 22280| | | | | |
-| 3|ConfigNode|Running| 127.0.0.1| 22281| 22282| | | | | |
-| 1| DataNode|Running| 127.0.0.1| 9003| | 127.0.0.1| 6667| 40010| 50010| 8777|
-| 4| DataNode|Running| 127.0.0.1| 9004| | 127.0.0.1| 6668| 40011| 50011| 8778|
-| 5| DataNode|Running| 127.0.0.1| 9005| | 127.0.0.1| 6669| 40012| 50012| 8779|
+| 0|ConfigNode|Running| 127.0.0.1| 10710| 10720| | | | | |
+| 2|ConfigNode|Running| 127.0.0.1| 10711| 10721| | | | | |
+| 3|ConfigNode|Running| 127.0.0.1| 10712| 10722| | | | | |
+| 1| DataNode|Running| 127.0.0.1| 10730| | 127.0.0.1| 6667| 10760| 10750| 10740|
+| 4| DataNode|Running| 127.0.0.1| 10731| | 127.0.0.1| 6668| 10761| 10751| 10741|
+| 5| DataNode|Running| 127.0.0.1| 10732| | 127.0.0.1| 6669| 10762| 10752| 10742|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
Total line number = 6
It costs 0.012s
@@ -150,7 +150,7 @@ It costs 0.012s
+ Remove a ConfigNode:
```
# Removing by ip:port
-./cluster0/sbin/remove-confignode.sh 127.0.0.1:22279
+./cluster0/sbin/remove-confignode.sh 127.0.0.1:10711
# Removing by Node index
./cluster0/sbin/remove-confignode.sh 2
@@ -173,10 +173,10 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort|RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277| 22278| | | | | |
-| 3|ConfigNode|Running| 127.0.0.1| 22281| 22282| | | | | |
-| 1| DataNode|Running| 127.0.0.1| 9003| | 127.0.0.1| 6667| 40010| 50010| 8777|
-| 5| DataNode|Running| 127.0.0.1| 9005| | 127.0.0.1| 6669| 40012| 50012| 8779|
+| 0|ConfigNode|Running| 127.0.0.1| 10710| 10720| | | | | |
+| 3|ConfigNode|Running| 127.0.0.1| 10712| 10722| | | | | |
+| 1| DataNode|Running| 127.0.0.1| 10730| | 127.0.0.1| 6667| 10760| 10750| 10740|
+| 5| DataNode|Running| 127.0.0.1| 10732| | 127.0.0.1| 6669| 10762| 10752| 10742|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
Total line number = 4
It costs 0.005s
diff --git a/docs/UserGuide/QuickStart/WayToGetIoTDB.md b/docs/UserGuide/QuickStart/WayToGetIoTDB.md
index e5c3f4a27b..4079e63a26 100644
--- a/docs/UserGuide/QuickStart/WayToGetIoTDB.md
+++ b/docs/UserGuide/QuickStart/WayToGetIoTDB.md
@@ -100,10 +100,10 @@ docker run -d --name iotdb-service \
--ip 172.18.0.6 \
-p 6667:6667 \
-e cn_internal_address=iotdb-service \
- -e cn_target_config_node_list=iotdb-service:22277 \
+ -e cn_target_config_node_list=iotdb-service:10710 \
-e dn_rpc_address=iotdb-service \
-e dn_internal_address=iotdb-service \
- -e dn_target_config_node_list=iotdb-service:22277 \
+ -e dn_target_config_node_list=iotdb-service:10710 \
apache/iotdb:1.0.0-standalone
# execute SQL
docker exec -ti iotdb-service /iotdb/sbin/start-cli.sh -h iotdb-service
@@ -126,10 +126,10 @@ services:
- "6667:6667"
environment:
- cn_internal_address=iotdb-service
- - cn_target_config_node_list=iotdb-service:22277
+ - cn_target_config_node_list=iotdb-service:10710
- dn_rpc_address=iotdb-service
- dn_internal_address=iotdb-service
- - dn_target_config_node_list=iotdb-service:22277
+ - dn_target_config_node_list=iotdb-service:10710
volumes:
- ./data:/iotdb/data
- ./logs:/iotdb/logs
@@ -154,11 +154,11 @@ services:
image: apache/iotdb:1.0.0-confignode
container_name: iotdb-confignode
ports:
- - "22277:22277"
- - "22278:22278"
+ - "10710:10710"
+ - "10720:10720"
environment:
- cn_internal_address=iotdb-2
- - cn_target_config_node_list=iotdb-1:22277
+ - cn_target_config_node_list=iotdb-1:10710
- schema_replication_factor=3
- schema_region_consensus_protocol_class=org.apache.iotdb.consensus.ratis.RatisConsensus
- config_node_consensus_protocol_class=org.apache.iotdb.consensus.ratis.RatisConsensus
@@ -175,14 +175,14 @@ services:
container_name: iotdb-datanode
ports:
- "6667:6667"
- - "8777:8777"
- - "9003:9003"
- - "50010:50010"
- - "40010:40010"
+ - "10740:10740"
+ - "10730:10730"
+ - "10750:10750"
+ - "10760:10760"
environment:
- dn_rpc_address=iotdb-2
- dn_internal_address=iotdb-2
- - dn_target_config_node_list=iotdb-1:22277
+ - dn_target_config_node_list=iotdb-1:10710
- data_replication_factor=3
- data_region_consensus_protocol_class=org.apache.iotdb.consensus.iot.IoTConsensus
- schema_replication_factor=3
@@ -195,7 +195,7 @@ services:
network_mode: "host"
```
Notice：
-1. The `dn_target_config_node_list` of three nodes must the same and it is the first starting node of `iotdb-1` with the cn_internal_port of 22277。
+1. The `dn_target_config_node_list` of three nodes must the same and it is the first starting node of `iotdb-1` with the cn_internal_port of 10710。
2. In this docker-compose file，`iotdb-2` should be replace with the real IP or hostname of each node to generate docker compose files in the other nodes.
3. The services would talk with each other, so they need map the /etc/hosts file or add the `extra_hosts` to the docker compose file.
4. We must start the IoTDB services of `iotdb-1` first at the first time of starting.
diff --git a/docs/UserGuide/Reference/ConfigNode-Config-Manual.md b/docs/UserGuide/Reference/ConfigNode-Config-Manual.md
index 261f8545a1..8f300afbc1 100644
--- a/docs/UserGuide/Reference/ConfigNode-Config-Manual.md
+++ b/docs/UserGuide/Reference/ConfigNode-Config-Manual.md
@@ -82,7 +82,7 @@ The global configuration of cluster is in ConfigNode.
|:---:|:---|
|Description| ConfigNode internal service port|
|Type| Short Int : [0,65535] |
-|Default| 22277 |
+|Default| 10710 |
|Effective|After restarting system|
### Consensus
@@ -93,7 +93,7 @@ The global configuration of cluster is in ConfigNode.
|:---:|:---|
|Description| ConfigNode data Consensus Port |
|Type| Short Int : [0,65535] |
-|Default| 22278 |
+|Default| 10720 |
|Effective|After restarting system|
### Target Config Nodes
@@ -104,7 +104,7 @@ The global configuration of cluster is in ConfigNode.
|:---:|:----------------------------------------------------------------------|
|Description| Target ConfigNode address, for current ConfigNode to join the cluster |
|Type| String |
-|Default| 127.0.0.1:22277 |
+|Default| 127.0.0.1:10710 |
|Effective| After restarting system |
### Directory configuration
diff --git a/docs/UserGuide/Reference/DataNode-Config-Manual.md b/docs/UserGuide/Reference/DataNode-Config-Manual.md
index 267b79cbbc..34dd38a75e 100644
--- a/docs/UserGuide/Reference/DataNode-Config-Manual.md
+++ b/docs/UserGuide/Reference/DataNode-Config-Manual.md
@@ -139,7 +139,7 @@ The permission definitions are in ${IOTDB\_CONF}/conf/jmx.access.
|:---:|:-------------------------------|
|Description| DataNode internal service port |
|Type| int |
-|Default| 9003 |
+|Default| 10730 |
|Effective| After restarting system |
* dn\_mpp\_data\_exchange\_port
@@ -148,7 +148,7 @@ The permission definitions are in ${IOTDB\_CONF}/conf/jmx.access.
|:---:|:---|
|Description| MPP data exchange port |
|Type| int |
-|Default| 8777 |
+|Default| 10740 |
|Effective|After restarting system|
* dn\_schema\_region\_consensus\_port
@@ -157,7 +157,7 @@ The permission definitions are in ${IOTDB\_CONF}/conf/jmx.access.
|:---:|:---|
|Description| DataNode Schema replica communication port for consensus |
|Type| int |
-|Default| 50010 |
+|Default| 10750 |
|Effective|After restarting system|
* dn\_data\_region\_consensus\_port
@@ -166,7 +166,7 @@ The permission definitions are in ${IOTDB\_CONF}/conf/jmx.access.
|:---:|:---|
|Description| DataNode Data replica communication port for consensus |
|Type| int |
-|Default| 40010 |
+|Default| 10760 |
|Effective|After restarting system|
* dn\_join\_cluster\_retry\_interval\_ms
@@ -186,7 +186,7 @@ The permission definitions are in ${IOTDB\_CONF}/conf/jmx.access.
|:---:|:------------------------------------------------|
|Description| ConfigNode Address for DataNode to join cluster |
|Type| String |
-|Default| 127.0.0.1:22277 |
+|Default| 127.0.0.1:10710 |
|Effective| After restarting system |
### Connection Configuration
diff --git a/docs/zh/UserGuide/Cluster/Cluster-Maintenance.md b/docs/zh/UserGuide/Cluster/Cluster-Maintenance.md
index acf8e028af..6676e9fee1 100644
--- a/docs/zh/UserGuide/Cluster/Cluster-Maintenance.md
+++ b/docs/zh/UserGuide/Cluster/Cluster-Maintenance.md
@@ -34,9 +34,9 @@ IoTDB> show confignodes
+------+-------+---------------+------------+--------+
|NodeID| Status|InternalAddress|InternalPort| Role|
+------+-------+---------------+------------+--------+
-| 0|Running| 127.0.0.1| 22277| Leader|
-| 1|Running| 127.0.0.1| 22279|Follower|
-| 2|Running| 127.0.0.1| 22281|Follower|
+| 0|Running| 127.0.0.1| 10710| Leader|
+| 1|Running| 127.0.0.1| 10711|Follower|
+| 2|Running| 127.0.0.1| 10712|Follower|
+------+-------+---------------+------------+--------+
Total line number = 3
It costs 0.030s
@@ -111,11 +111,11 @@ IoTDB> show cluster
+------+----------+-------+---------------+------------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|
+------+----------+-------+---------------+------------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277|
-| 1|ConfigNode|Running| 127.0.0.1| 22279|
-| 2|ConfigNode|Running| 127.0.0.1| 22281|
-| 3| DataNode|Running| 127.0.0.1| 9003|
-| 4| DataNode|Running| 127.0.0.1| 9005|
+| 0|ConfigNode|Running| 127.0.0.1| 10710|
+| 1|ConfigNode|Running| 127.0.0.1| 10711|
+| 2|ConfigNode|Running| 127.0.0.1| 10712|
+| 3| DataNode|Running| 127.0.0.1| 10730|
+| 4| DataNode|Running| 127.0.0.1| 10732|
| 5| DataNode|Running| 127.0.0.1| 9007|
+------+----------+-------+---------------+------------+
Total line number = 6
@@ -128,11 +128,11 @@ IoTDB> show cluster
+------+----------+-------+---------------+------------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|
+------+----------+-------+---------------+------------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277|
-| 1|ConfigNode|Unknown| 127.0.0.1| 22279|
-| 2|ConfigNode|Running| 127.0.0.1| 22281|
-| 3| DataNode|Running| 127.0.0.1| 9003|
-| 4| DataNode|Running| 127.0.0.1| 9005|
+| 0|ConfigNode|Running| 127.0.0.1| 10710|
+| 1|ConfigNode|Unknown| 127.0.0.1| 10711|
+| 2|ConfigNode|Running| 127.0.0.1| 10712|
+| 3| DataNode|Running| 127.0.0.1| 10730|
+| 4| DataNode|Running| 127.0.0.1| 10732|
| 5| DataNode|Running| 127.0.0.1| 9007|
+------+----------+-------+---------------+------------+
Total line number = 6
@@ -150,12 +150,12 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort|RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277| 22278| | | | | |
-| 1|ConfigNode|Running| 127.0.0.1| 22279| 22280| | | | | |
-| 2|ConfigNode|Running| 127.0.0.1| 22281| 22282| | | | | |
-| 3| DataNode|Running| 127.0.0.1| 9003| | 127.0.0.1| 6667| 40010| 50010| 8777|
-| 4| DataNode|Running| 127.0.0.1| 9004| | 127.0.0.1| 6668| 40011| 50011| 8778|
-| 5| DataNode|Running| 127.0.0.1| 9005| | 127.0.0.1| 6669| 40012| 50012| 8779|
+| 0|ConfigNode|Running| 127.0.0.1| 10710| 10720| | | | | |
+| 1|ConfigNode|Running| 127.0.0.1| 10711| 10721| | | | | |
+| 2|ConfigNode|Running| 127.0.0.1| 10712| 10722| | | | | |
+| 3| DataNode|Running| 127.0.0.1| 10730| | 127.0.0.1| 6667| 10760| 10750| 10740|
+| 4| DataNode|Running| 127.0.0.1| 10731| | 127.0.0.1| 6668| 10761| 10751| 10741|
+| 5| DataNode|Running| 127.0.0.1| 10732| | 127.0.0.1| 6669| 10762| 10752| 10742|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
Total line number = 6
It costs 0.340s
diff --git a/docs/zh/UserGuide/Cluster/Cluster-Setup.md b/docs/zh/UserGuide/Cluster/Cluster-Setup.md
index 8b733164bc..455693ce8d 100644
--- a/docs/zh/UserGuide/Cluster/Cluster-Setup.md
+++ b/docs/zh/UserGuide/Cluster/Cluster-Setup.md
@@ -30,7 +30,7 @@
3. 关闭交换内存。
4. 首次启动ConfigNode节点时，确保已清空ConfigNode节点的data/confignode目录；首次启动DataNode节点时，确保已清空DataNode节点的data/datanode目录。
5. 如果整个集群处在可信环境下，可以关闭机器上的防火墙选项。
-6. 在集群默认配置中，ConfigNode 会占用端口 22277 和 22278，DataNode 会占用端口 6667、8777、9003、40010 和 50010，
+6. 在集群默认配置中，ConfigNode 会占用端口 10710 和 10720，DataNode 会占用端口 6667、10740、10730、10760 和 10750，
请确保这些端口未被占用，或者手动修改配置文件中的端口配置。
# 3. 安装包获取
@@ -126,9 +126,9 @@ mvn clean package -pl distribution -am -DskipTests
| **配置项** | **说明** | **默认** | **用法** |
|--------------------------------|--------------------------------------|-----------------|------------------------------------------------------------------------------------------------------------------------------------------------------|
| cn\_internal\_address | ConfigNode 在集群内部通讯使用的地址 | 127.0.0.1 | 设置为服务器的 IPV4 地址或域名 |
-| cn\_internal\_port | ConfigNode 在集群内部通讯使用的端口 | 22277 | 设置为任意未占用端口 |
-| cn\_consensus\_port | ConfigNode 副本组共识协议通信使用的端口 | 22278 | 设置为任意未占用端口 |
-| cn\_target\_config\_node\_list | 节点注册加入集群时连接的 ConfigNode 的地址。注：只能配置一个 | 127.0.0.1:22277 | 对于 Seed-ConfigNode，设置为自己的 cn\_internal\_address:cn\_internal\_port；对于其它 ConfigNode，设置为另一个正在运行的 ConfigNode 的 cn\_internal\_address:cn\_internal\_port |
+| cn\_internal\_port | ConfigNode 在集群内部通讯使用的端口 | 10710 | 设置为任意未占用端口 |
+| cn\_consensus\_port | ConfigNode 副本组共识协议通信使用的端口 | 10720 | 设置为任意未占用端口 |
+| cn\_target\_config\_node\_list | 节点注册加入集群时连接的 ConfigNode 的地址。注：只能配置一个 | 127.0.0.1:10710 | 对于 Seed-ConfigNode，设置为自己的 cn\_internal\_address:cn\_internal\_port；对于其它 ConfigNode，设置为另一个正在运行的 ConfigNode 的 cn\_internal\_address:cn\_internal\_port |
**注意：上述配置项在节点启动后即不可更改，且务必保证所有端口均未被占用，否则节点无法启动。**
@@ -141,11 +141,11 @@ mvn clean package -pl distribution -am -DskipTests
| dn\_rpc\_address | 客户端 RPC 服务的地址 | 127.0.0.1 | 设置为服务器的 IPV4 地址或域名 |
| dn\_rpc\_port | 客户端 RPC 服务的端口 | 6667 | 设置为任意未占用端口 |
| dn\_internal\_address | DataNode 在集群内部接收控制流使用的地址 | 127.0.0.1 | 设置为服务器的 IPV4 地址或域名 |
-| dn\_internal\_port | DataNode 在集群内部接收控制流使用的端口 | 9003 | 设置为任意未占用端口 |
-| dn\_mpp\_data\_exchange\_port | DataNode 在集群内部接收数据流使用的端口 | 8777 | 设置为任意未占用端口 |
-| dn\_data\_region\_consensus\_port | DataNode 的数据副本间共识协议通信的端口 | 50010 | 设置为任意未占用端口 |
-| dn\_schema\_region\_consensus\_port | DataNode 的元数据副本间共识协议通信的端口 | 40010 | 设置为任意未占用端口 |
-| dn\_target\_config\_node\_list | 集群中正在运行的 ConfigNode 地址 | 127.0.0.1:22277 | 设置为任意正在运行的 ConfigNode 的 cn\_internal\_address:cn\_internal\_port，可设置多个，用逗号（","）隔开 |
+| dn\_internal\_port | DataNode 在集群内部接收控制流使用的端口 | 10730 | 设置为任意未占用端口 |
+| dn\_mpp\_data\_exchange\_port | DataNode 在集群内部接收数据流使用的端口 | 10740 | 设置为任意未占用端口 |
+| dn\_data\_region\_consensus\_port | DataNode 的数据副本间共识协议通信的端口 | 10750 | 设置为任意未占用端口 |
+| dn\_schema\_region\_consensus\_port | DataNode 的元数据副本间共识协议通信的端口 | 10760 | 设置为任意未占用端口 |
+| dn\_target\_config\_node\_list | 集群中正在运行的 ConfigNode 地址 | 127.0.0.1:10710 | 设置为任意正在运行的 ConfigNode 的 cn\_internal\_address:cn\_internal\_port，可设置多个，用逗号（","）隔开 |
**注意：上述配置项在节点启动后即不可更改，且务必保证所有端口均未被占用，否则节点无法启动。**
@@ -279,8 +279,8 @@ DataNode 的其它配置参数可参考
## 6.3 验证集群
以在6台服务器上启动的3C3D（3个ConfigNode 和 3个DataNode）集群为例，
-这里假设3个ConfigNode的IP地址依次为192.168.1.10、192.168.1.11、192.168.1.12，且3个ConfigNode启动时均使用了默认的端口22277与22278；
-3个DataNode的IP地址依次为192.168.1.20、192.168.1.21、192.168.1.22，且3个DataNode启动时均使用了默认的端口9003、6667、40010、50010与8777。
+这里假设3个ConfigNode的IP地址依次为192.168.1.10、192.168.1.11、192.168.1.12，且3个ConfigNode启动时均使用了默认的端口10710与10720；
+3个DataNode的IP地址依次为192.168.1.20、192.168.1.21、192.168.1.22，且3个DataNode启动时均使用了默认的端口10730、6667、10760、10750与10740。
当按照6.1步骤成功启动集群后，在 Cli 执行 `show cluster details`，看到的结果应当如下：
@@ -289,12 +289,12 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+------------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort| RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+------------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 192.168.1.10| 22277| 22278| | | | | |
-| 2|ConfigNode|Running| 192.168.1.11| 22277| 22278| | | | | |
-| 3|ConfigNode|Running| 192.168.1.12| 22277| 22278| | | | | |
-| 1| DataNode|Running| 192.168.1.20| 9003| |192.168.1.20| 6667| 40010| 50010| 8777|
-| 4| DataNode|Running| 192.168.1.21| 9003| |192.168.1.21| 6667| 40010| 50010| 8777|
-| 5| DataNode|Running| 192.168.1.22| 9003| |192.168.1.22| 6667| 40010| 50010| 8777|
+| 0|ConfigNode|Running| 192.168.1.10| 10710| 10720| | | | | |
+| 2|ConfigNode|Running| 192.168.1.11| 10710| 10720| | | | | |
+| 3|ConfigNode|Running| 192.168.1.12| 10710| 10720| | | | | |
+| 1| DataNode|Running| 192.168.1.20| 10730| |192.168.1.20| 6667| 10760| 10750| 10740|
+| 4| DataNode|Running| 192.168.1.21| 10730| |192.168.1.21| 6667| 10760| 10750| 10740|
+| 5| DataNode|Running| 192.168.1.22| 10730| |192.168.1.22| 6667| 10760| 10750| 10740|
+------+----------+-------+---------------+------------+-------------------+------------+-------+-----------------+-------------------+-------+
Total line number = 6
It costs 0.012s
diff --git a/docs/zh/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md b/docs/zh/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
index c269441b21..38e3977c6d 100644
--- a/docs/zh/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
+++ b/docs/zh/UserGuide/Edge-Cloud-Collaboration/Sync-Tool.md
@@ -345,16 +345,16 @@ It costs 0.134s
- 执行 `CREATE PIPE p to demo` 提示 `PIPE [p] is STOP, please retry after drop it.`
- 原因：当前 Pipe 已存在
- 解决方案：删除 Pipe 后重新创建
-- 执行 `CREATE PIPE p to demo`提示 `Fail to create PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:9005)}.`
+- 执行 `CREATE PIPE p to demo`提示 `Fail to create PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:10732)}.`
- 原因：存在状态为 Running 的 DataNode 无法连通
- 解决方案：执行 `SHOW DATANODES` 语句，检查无法连通的 DataNode 网络，或等待其状态变为 Unknown 后重新执行语句。
-- 执行 `START PIPE p` 提示 `Fail to start PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:9005)}.`
+- 执行 `START PIPE p` 提示 `Fail to start PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:10732)}.`
- 原因：存在状态为 Running 的 DataNode 无法连通
- 解决方案：执行 `SHOW DATANODES` 语句，检查无法连通的 DataNode 网络，或等待其状态变为 Unknown 后重新执行语句。
-- 执行 `STOP PIPE p` 提示 `Fail to stop PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:9005)}.`
+- 执行 `STOP PIPE p` 提示 `Fail to stop PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:10732)}.`
- 原因：存在状态为 Running 的 DataNode 无法连通
- 解决方案：执行 `SHOW DATANODES` 语句，检查无法连通的 DataNode 网络，或等待其状态变为 Unknown 后重新执行语句。
-- 执行 `DROP PIPE p` 提示 `Fail to DROP_PIPE because Fail to drop PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:9005)}. Please execute [DROP PIPE p] later to retry.`
+- 执行 `DROP PIPE p` 提示 `Fail to DROP_PIPE because Fail to drop PIPE [p] because Connection refused on DataNode: {id=2, internalEndPoint=TEndPoint(ip:127.0.0.1, port:10732)}. Please execute [DROP PIPE p] later to retry.`
- 原因：存在状态为 Running 的 DataNode 无法连通，Pipe 已在部分节点上被删除，状态被置为 ***DROP***。
- 解决方案：执行 `SHOW DATANODES` 语句，检查无法连通的 DataNode 网络，或等待其状态变为 Unknown 后重新执行语句。
- 运行时日志提示 `org.apache.iotdb.commons.exception.IoTDBException: root.** already been created as database`
diff --git a/docs/zh/UserGuide/QuickStart/ClusterQuickStart.md b/docs/zh/UserGuide/QuickStart/ClusterQuickStart.md
index 0d76702862..c8bc12e3a6 100644
--- a/docs/zh/UserGuide/QuickStart/ClusterQuickStart.md
+++ b/docs/zh/UserGuide/QuickStart/ClusterQuickStart.md
@@ -51,8 +51,8 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort|RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277| 22278| | | | | |
-| 1| DataNode|Running| 127.0.0.1| 9003| | 127.0.0.1| 6667| 40010| 50010| 8777|
+| 0|ConfigNode|Running| 127.0.0.1| 10710| 10720| | | | | |
+| 1| DataNode|Running| 127.0.0.1| 10730| | 127.0.0.1| 6667| 10760| 10750| 10740|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
Total line number = 2
It costs 0.242s
@@ -71,9 +71,9 @@ It costs 0.242s
| **配置项** | **值** |
|--------------------------------|-----------------|
| cn\_internal\_address | 127.0.0.1 |
-| cn\_internal\_port | 22279 |
-| cn\_consensus\_port | 22280 |
-| cn\_target\_config\_node\_list | 127.0.0.1:22277 |
+| cn\_internal\_port | 10711 |
+| cn\_consensus\_port | 10721 |
+| cn\_target\_config\_node\_list | 127.0.0.1:10710 |
+ 修改 DataNode 配置：
@@ -82,11 +82,11 @@ It costs 0.242s
| dn\_rpc\_address | 127.0.0.1 |
| dn\_rpc\_port | 6668 |
| dn\_internal\_address | 127.0.0.1 |
-| dn\_internal\_port | 9004 |
-| dn\_mpp\_data\_exchange\_port | 8778 |
-| dn\_data\_region\_consensus\_port | 40011 |
-| dn\_schema\_region\_consensus\_port | 50011 |
-| dn\_target\_config\_node\_list | 127.0.0.1:22277 |
+| dn\_internal\_port | 10731 |
+| dn\_mpp\_data\_exchange\_port | 10741 |
+| dn\_data\_region\_consensus\_port | 10761 |
+| dn\_schema\_region\_consensus\_port | 10751 |
+| dn\_target\_config\_node\_list | 127.0.0.1:10710 |
对于 cluster2 目录：
@@ -95,9 +95,9 @@ It costs 0.242s
| **配置项** | **值** |
|--------------------------------|-----------------|
| cn\_internal\_address | 127.0.0.1 |
-| cn\_internal\_port | 22281 |
-| cn\_consensus\_port | 22282 |
-| cn\_target\_config\_node\_list | 127.0.0.1:22277 |
+| cn\_internal\_port | 10712 |
+| cn\_consensus\_port | 10722 |
+| cn\_target\_config\_node\_list | 127.0.0.1:10710 |
+ 修改 DataNode 配置：
@@ -106,11 +106,11 @@ It costs 0.242s
| dn\_rpc\_address | 127.0.0.1 |
| dn\_rpc\_port | 6669 |
| dn\_internal\_address | 127.0.0.1 |
-| dn\_internal\_port | 9005 |
-| dn\_mpp\_data\_exchange\_port | 8779 |
-| dn\_data\_region\_consensus\_port | 40012 |
-| dn\_schema\_region\_consensus\_port | 50012 |
-| dn\_target\_config\_node\_list | 127.0.0.1:22277 |
+| dn\_internal\_port | 10732 |
+| dn\_mpp\_data\_exchange\_port | 10742 |
+| dn\_data\_region\_consensus\_port | 10762 |
+| dn\_schema\_region\_consensus\_port | 10752 |
+| dn\_target\_config\_node\_list | 127.0.0.1:10710 |
## 6. 集群扩容
@@ -131,12 +131,12 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort|RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277| 22278| | | | | |
-| 2|ConfigNode|Running| 127.0.0.1| 22279| 22280| | | | | |
-| 3|ConfigNode|Running| 127.0.0.1| 22281| 22282| | | | | |
-| 1| DataNode|Running| 127.0.0.1| 9003| | 127.0.0.1| 6667| 40010| 50010| 8777|
-| 4| DataNode|Running| 127.0.0.1| 9004| | 127.0.0.1| 6668| 40011| 50011| 8778|
-| 5| DataNode|Running| 127.0.0.1| 9005| | 127.0.0.1| 6669| 40012| 50012| 8779|
+| 0|ConfigNode|Running| 127.0.0.1| 10710| 10720| | | | | |
+| 2|ConfigNode|Running| 127.0.0.1| 10711| 10721| | | | | |
+| 3|ConfigNode|Running| 127.0.0.1| 10712| 10722| | | | | |
+| 1| DataNode|Running| 127.0.0.1| 10730| | 127.0.0.1| 6667| 10760| 10750| 10740|
+| 4| DataNode|Running| 127.0.0.1| 10731| | 127.0.0.1| 6668| 10761| 10751| 10741|
+| 5| DataNode|Running| 127.0.0.1| 10732| | 127.0.0.1| 6669| 10762| 10752| 10742|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
Total line number = 6
It costs 0.012s
@@ -147,7 +147,7 @@ It costs 0.012s
+ 缩容一个 ConfigNode：
```
# 使用 ip:port 移除
-./cluster0/sbin/remove-confignode.sh 127.0.0.1:22279
+./cluster0/sbin/remove-confignode.sh 127.0.0.1:10711
# 使用节点编号移除
./cluster0/sbin/remove-confignode.sh 2
@@ -170,10 +170,10 @@ IoTDB> show cluster details
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
|NodeID| NodeType| Status|InternalAddress|InternalPort|ConfigConsensusPort|RpcAddress|RpcPort|DataConsensusPort|SchemaConsensusPort|MppPort|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
-| 0|ConfigNode|Running| 127.0.0.1| 22277| 22278| | | | | |
-| 3|ConfigNode|Running| 127.0.0.1| 22281| 22282| | | | | |
-| 1| DataNode|Running| 127.0.0.1| 9003| | 127.0.0.1| 6667| 40010| 50010| 8777|
-| 5| DataNode|Running| 127.0.0.1| 9005| | 127.0.0.1| 6669| 40012| 50012| 8779|
+| 0|ConfigNode|Running| 127.0.0.1| 10710| 10720| | | | | |
+| 3|ConfigNode|Running| 127.0.0.1| 10712| 10722| | | | | |
+| 1| DataNode|Running| 127.0.0.1| 10730| | 127.0.0.1| 6667| 10760| 10750| 10740|
+| 5| DataNode|Running| 127.0.0.1| 10732| | 127.0.0.1| 6669| 10762| 10752| 10742|
+------+----------+-------+---------------+------------+-------------------+----------+-------+-----------------+-------------------+-------+
Total line number = 4
It costs 0.005s
diff --git a/docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md b/docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md
index 26519e44ff..1c6afb04bd 100644
--- a/docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md
+++ b/docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md
@@ -103,10 +103,10 @@ docker run -d --name iotdb-service \
--ip 172.18.0.6 \
-p 6667:6667 \
-e cn_internal_address=iotdb-service \
- -e cn_target_config_node_list=iotdb-service:22277 \
+ -e cn_target_config_node_list=iotdb-service:10710 \
-e dn_rpc_address=iotdb-service \
-e dn_internal_address=iotdb-service \
- -e dn_target_config_node_list=iotdb-service:22277 \
+ -e dn_target_config_node_list=iotdb-service:10710 \
apache/iotdb:1.0.0-standalone
# 尝试使用命令行执行SQL
docker exec -ti iotdb-service /iotdb/sbin/start-cli.sh -h iotdb-service
@@ -128,10 +128,10 @@ services:
- "6667:6667"
environment:
- cn_internal_address=iotdb-service
- - cn_target_config_node_list=iotdb-service:22277
+ - cn_target_config_node_list=iotdb-service:10710
- dn_rpc_address=iotdb-service
- dn_internal_address=iotdb-service
- - dn_target_config_node_list=iotdb-service:22277
+ - dn_target_config_node_list=iotdb-service:10710
volumes:
- ./data:/iotdb/data
- ./logs:/iotdb/logs
@@ -155,11 +155,11 @@ services:
image: apache/iotdb:1.0.0-confignode
container_name: iotdb-confignode
ports:
- - "22277:22277"
- - "22278:22278"
+ - "10710:10710"
+ - "10720:10720"
environment:
- cn_internal_address=iotdb-2
- - cn_target_config_node_list=iotdb-1:22277
+ - cn_target_config_node_list=iotdb-1:10710
- schema_replication_factor=3
- schema_region_consensus_protocol_class=org.apache.iotdb.consensus.ratis.RatisConsensus
- config_node_consensus_protocol_class=org.apache.iotdb.consensus.ratis.RatisConsensus
@@ -176,14 +176,14 @@ services:
container_name: iotdb-datanode
ports:
- "6667:6667"
- - "8777:8777"
- - "9003:9003"
- - "50010:50010"
- - "40010:40010"
+ - "10740:10740"
+ - "10730:10730"
+ - "10750:10750"
+ - "10760:10760"
environment:
- dn_rpc_address=iotdb-2
- dn_internal_address=iotdb-2
- - dn_target_config_node_list=iotdb-1:22277
+ - dn_target_config_node_list=iotdb-1:10710
- data_replication_factor=3
- data_region_consensus_protocol_class=org.apache.iotdb.consensus.iot.IoTConsensus
- schema_replication_factor=3
diff --git a/docs/zh/UserGuide/Reference/ConfigNode-Config-Manual.md b/docs/zh/UserGuide/Reference/ConfigNode-Config-Manual.md
index e732d766fa..c3cf639c71 100644
--- a/docs/zh/UserGuide/Reference/ConfigNode-Config-Manual.md
+++ b/docs/zh/UserGuide/Reference/ConfigNode-Config-Manual.md
@@ -80,7 +80,7 @@ IoTDB 集群的全局配置通过 ConfigNode 配置。
|:------:|:----------------------|
| 描述 | ConfigNode 集群服务监听端口 |
| 类型 | Short Int : [0,65535] |
-| 默认值 | 22277 |
+| 默认值 | 10710 |
| 改后生效方式 | 重启服务生效 |
### 共识协议
@@ -91,7 +91,7 @@ IoTDB 集群的全局配置通过 ConfigNode 配置。
|:------:|:----------------------|
| 描述 | ConfigNode 的共识协议通信端口 |
| 类型 | Short Int : [0,65535] |
-| 默认值 | 22278 |
+| 默认值 | 10720 |
| 改后生效方式 | 重启服务生效 |
### 目标 Config Node 配置
@@ -102,7 +102,7 @@ IoTDB 集群的全局配置通过 ConfigNode 配置。
|:------:|:--------------------------------------|
| 描述 | 目标 ConfigNode 地址，ConfigNode 通过此地址加入集群 |
| 类型 | String |
-| 默认值 | 127.0.0.1:22277 |
+| 默认值 | 127.0.0.1:10710 |
| 改后生效方式 | 重启服务生效 |
diff --git a/docs/zh/UserGuide/Reference/DataNode-Config-Manual.md b/docs/zh/UserGuide/Reference/DataNode-Config-Manual.md
index 53f63f69f2..fad04934f0 100644
--- a/docs/zh/UserGuide/Reference/DataNode-Config-Manual.md
+++ b/docs/zh/UserGuide/Reference/DataNode-Config-Manual.md
@@ -122,7 +122,7 @@ IoTDB DataNode 与 Standalone 模式共用一套配置文件，均位于 IoTDB
|:---:|:-------------------|
|描述| DataNode 内网通信端口 |
|类型| int |
-|默认值| 9003 |
+|默认值| 10730 |
|改后生效方式| 重启服务生效 |
* dn\_mpp\_data\_exchange\_port
@@ -131,7 +131,7 @@ IoTDB DataNode 与 Standalone 模式共用一套配置文件，均位于 IoTDB
|:---:|:---|
|描述| MPP 数据交换端口 |
|类型| int |
-|默认值| 8777 |
+|默认值| 10740 |
|改后生效方式|重启服务生效|
* dn\_schema\_region\_consensus\_port
@@ -140,7 +140,7 @@ IoTDB DataNode 与 Standalone 模式共用一套配置文件，均位于 IoTDB
|:---:|:---|
|描述| DataNode 元数据副本的共识协议通信端口 |
|类型| int |
-|默认值| 50010 |
+|默认值| 10750 |
|改后生效方式|重启服务生效|
* dn\_data\_region\_consensus\_port
@@ -149,7 +149,7 @@ IoTDB DataNode 与 Standalone 模式共用一套配置文件，均位于 IoTDB
|:---:|:---|
|描述| DataNode 数据副本的共识协议通信端口 |
|类型| int |
-|默认值| 40010 |
+|默认值| 10760 |
|改后生效方式|重启服务生效|
* dn\_join\_cluster\_retry\_interval\_ms
@@ -169,7 +169,7 @@ IoTDB DataNode 与 Standalone 模式共用一套配置文件，均位于 IoTDB
|:---:|:------------------------------------|
|描述| ConfigNode 地址，DataNode 启动时通过此地址加入集群 |
|类型| String |
-|默认值| 127.0.0.1:22277 |
+|默认值| 127.0.0.1:10710 |
|改后生效方式| 重启服务生效 |
### 连接配置
diff --git a/grafana-plugin/yarn.lock b/grafana-plugin/yarn.lock
index 03bc88e69d..ca8eae53ef 100644
--- a/grafana-plugin/yarn.lock
+++ b/grafana-plugin/yarn.lock
@@ -279,7 +279,7 @@
"@babel/helpers@^7.13.10", "@babel/helpers@^7.17.2":
version "7.17.2"
- resolved "https://registry.npmmirror.com/@babel/helpers/-/helpers-7.17.2.tgz#23f0a0746c8e287773ccd27c14be428891f63417"
+ resolved "https://registry.npmmirror.com/@babel/helpers/-/helpers-7.17.2.tgz#23f0a0746c8e2107403ccd27c14be428891f63417"
integrity sha512-0Qu7RLR1dILozr/6M0xgj+DFPmi6Bnulgm9M8BVa9ZCWxDqlSnqt3cf8IDPB5m45sVXUZ0kuQAgUrdSFFH79fQ==
dependencies:
"@babel/template" "^7.16.7"
@@ -455,7 +455,7 @@
"@babel/plugin-syntax-import-meta@^7.8.3":
version "7.10.4"
- resolved "https://registry.npmmirror.com/@babel/plugin-syntax-import-meta/-/plugin-syntax-import-meta-7.10.4.tgz#ee601348c370fa334d2207be158777496521fd51"
+ resolved "https://registry.npmmirror.com/@babel/plugin-syntax-import-meta/-/plugin-syntax-import-meta-7.10.4.tgz#ee601348c370fa334d2207be1510740496521fd51"
integrity sha512-Yqfm+XDx0+Prh3VSeEQCPU81yC+JWZ2pDPFSS4ZdpfZhp4MkFMaDC1UqseovEKwSUpnIL7+vK+Clp7bfh0iD7g==
dependencies:
"@babel/helper-plugin-utils" "^7.10.4"
@@ -7277,7 +7277,7 @@ istanbul-lib-instrument@^3.3.0:
istanbul-lib-instrument@^4.0.3:
version "4.0.3"
- resolved "https://registry.npmmirror.com/istanbul-lib-instrument/-/istanbul-lib-instrument-4.0.3.tgz#873c6fff897450118222774696a3f28902d77c1d"
+ resolved "https://registry.npmmirror.com/istanbul-lib-instrument/-/istanbul-lib-instrument-4.0.3.tgz#873c6fff897450118107104696a3f28902d77c1d"
integrity sha512-BXgQl9kf4WTCPCCpmFGoJkz/+uhvm7h7PFKUYxh7qarQd3ER33vHG//qaE8eN25l07YqZPpHXU9I09l/RD5aGQ==
dependencies:
"@babel/core" "^7.7.5"
diff --git a/integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java b/integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
index 0187623e7d..9cf6344f9e 100644
--- a/integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
+++ b/integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
@@ -163,7 +163,7 @@ public class RemoteServerEnv implements BaseEnv {
@Override
public IConfigNodeRPCService.Iface getLeaderConfigNodeConnection() throws ClientManagerException {
- return clientManager.borrowClient(new TEndPoint(ip_addr, 22277));
+ return clientManager.borrowClient(new TEndPoint(ip_addr, 10710));
}
@Override
diff --git a/node-commons/src/assembly/resources/sbin/iotdb-common.sh b/node-commons/src/assembly/resources/sbin/iotdb-common.sh
index b41b20a7f4..cc748e946d 100755
--- a/node-commons/src/assembly/resources/sbin/iotdb-common.sh
+++ b/node-commons/src/assembly/resources/sbin/iotdb-common.sh
@@ -171,10 +171,10 @@ checkDataNodePortUsages () {
else
echo "Warning: cannot find iotdb-datanode.properties, check the default configuration"
dn_rpc_port=6667
- dn_internal_port=9003
- dn_mpp_data_exchange_port=8777
- dn_schema_region_consensus_port=50010
- dn_data_region_consensus_port=40010
+ dn_internal_port=10730
+ dn_mpp_data_exchange_port=10740
+ dn_schema_region_consensus_port=10750
+ dn_data_region_consensus_port=10760
fi
if type lsof >/dev/null 2>&1; then
PID=$(lsof -t -i:"${dn_rpc_port}" -sTCP:LISTEN)
@@ -252,8 +252,8 @@ checkConfigNodePortUsages () {
cn_consensus_port=$(sed '/^cn_consensus_port=/!d;s/.*=//' "${CONFIGNODE_HOME}"/conf/iotdb-confignode.properties)
else
echo "Cannot find iotdb-confignode.properties, check the default configuration"
- cn_internal_port=22277
- cn_consensus_port=22278
+ cn_internal_port=10710
+ cn_consensus_port=10720
fi
if type lsof >/dev/null 2>&1; then
PID=$(lsof -t -i:"${cn_internal_port}" -sTCP:LISTEN)
diff --git a/node-commons/src/test/java/org/apache/iotdb/commons/client/ClientManagerTest.java b/node-commons/src/test/java/org/apache/iotdb/commons/client/ClientManagerTest.java
index 18bf4bcd38..1375423486 100644
--- a/node-commons/src/test/java/org/apache/iotdb/commons/client/ClientManagerTest.java
+++ b/node-commons/src/test/java/org/apache/iotdb/commons/client/ClientManagerTest.java
@@ -42,7 +42,7 @@ import static org.mockito.Mockito.mock;
public class ClientManagerTest {
- private final TEndPoint endPoint = new TEndPoint("localhost", 9003);
+ private final TEndPoint endPoint = new TEndPoint("localhost", 10730);
private MockInternalRPCService service;
diff --git a/node-commons/src/test/java/org/apache/iotdb/commons/utils/NodeUrlUtilsTest.java b/node-commons/src/test/java/org/apache/iotdb/commons/utils/NodeUrlUtilsTest.java
index fca5f407ab..977ab57039 100644
--- a/node-commons/src/test/java/org/apache/iotdb/commons/utils/NodeUrlUtilsTest.java
+++ b/node-commons/src/test/java/org/apache/iotdb/commons/utils/NodeUrlUtilsTest.java
@@ -48,13 +48,13 @@ public class NodeUrlUtilsTest {
final List<TConfigNodeLocation> configNodeLocations =
Arrays.asList(
new TConfigNodeLocation(
- 0, new TEndPoint("0.0.0.0", 22277), new TEndPoint("0.0.0.0", 22278)),
+ 0, new TEndPoint("0.0.0.0", 10710), new TEndPoint("0.0.0.0", 10720)),
new TConfigNodeLocation(
- 1, new TEndPoint("0.0.0.0", 22279), new TEndPoint("0.0.0.0", 22280)),
+ 1, new TEndPoint("0.0.0.0", 10711), new TEndPoint("0.0.0.0", 10721)),
new TConfigNodeLocation(
- 2, new TEndPoint("0.0.0.0", 22281), new TEndPoint("0.0.0.0", 22282)));
+ 2, new TEndPoint("0.0.0.0", 10712), new TEndPoint("0.0.0.0", 10722)));
final String configNodeUrls =
- "0,0.0.0.0:22277,0.0.0.0:22278;1,0.0.0.0:22279,0.0.0.0:22280;2,0.0.0.0:22281,0.0.0.0:22282";
+ "0,0.0.0.0:10710,0.0.0.0:10720;1,0.0.0.0:10711,0.0.0.0:10721;2,0.0.0.0:10712,0.0.0.0:10722";
Assert.assertEquals(configNodeUrls, NodeUrlUtils.convertTConfigNodeUrls(configNodeLocations));
Assert.assertEquals(configNodeLocations, NodeUrlUtils.parseTConfigNodeUrls(configNodeUrls));
diff --git a/node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtilsTest.java b/node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtilsTest.java
index 31972fc30b..18a679ed2a 100644
--- a/node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtilsTest.java
+++ b/node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftCommonsSerDeUtilsTest.java
@@ -64,10 +64,10 @@ public class ThriftCommonsSerDeUtilsTest {
TDataNodeLocation dataNodeLocation0 = new TDataNodeLocation();
dataNodeLocation0.setDataNodeId(0);
dataNodeLocation0.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation0.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation0.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation0.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation0.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation0.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation0.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation0.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation0.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
try (PublicBAOS byteArrayOutputStream = new PublicBAOS();
DataOutputStream outputStream = new DataOutputStream(byteArrayOutputStream)) {
@@ -128,10 +128,10 @@ public class ThriftCommonsSerDeUtilsTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(i);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667 + i));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003 + i));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777 + i));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010 + i));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010 + i));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730 + i));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740 + i));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760 + i));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750 + i));
regionReplicaSet0.getDataNodeLocations().add(dataNodeLocation);
}
try (PublicBAOS byteArrayOutputStream = new PublicBAOS();
diff --git a/node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtilsTest.java b/node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtilsTest.java
index 6c85a7b3fe..24aee00bf6 100644
--- a/node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtilsTest.java
+++ b/node-commons/src/test/java/org/apache/iotdb/commons/utils/ThriftConfigNodeSerDeUtilsTest.java
@@ -57,7 +57,7 @@ public class ThriftConfigNodeSerDeUtilsTest {
public void readWriteTConfigNodeLocationTest() {
TConfigNodeLocation configNodeLocation0 =
new TConfigNodeLocation(
- 0, new TEndPoint("0.0.0.0", 22277), new TEndPoint("0.0.0.0", 22278));
+ 0, new TEndPoint("0.0.0.0", 10710), new TEndPoint("0.0.0.0", 10720));
ThriftConfigNodeSerDeUtils.serializeTConfigNodeLocation(configNodeLocation0, buffer);
buffer.flip();
diff --git a/server/src/assembly/resources/conf/iotdb-datanode.properties b/server/src/assembly/resources/conf/iotdb-datanode.properties
index 7eea86f87f..03ea81c3a4 100644
--- a/server/src/assembly/resources/conf/iotdb-datanode.properties
+++ b/server/src/assembly/resources/conf/iotdb-datanode.properties
@@ -39,22 +39,22 @@ dn_internal_address=127.0.0.1
# Used for communication inside cluster.
# Bind with dn_internal_address
# Datatype: int
-dn_internal_port=9003
+dn_internal_port=10730
# Port for data exchange among DataNodes inside cluster
# Bind with dn_internal_address
# Datatype: int
-dn_mpp_data_exchange_port=8777
+dn_mpp_data_exchange_port=10740
# port for consensus's communication for schema region inside cluster.
# Bind with dn_internal_address
# Datatype: int
-dn_schema_region_consensus_port=50010
+dn_schema_region_consensus_port=10750
# port for consensus's communication for data region inside cluster.
# Bind with dn_internal_address
# Datatype: int
-dn_data_region_consensus_port=40010
+dn_data_region_consensus_port=10760
# Datatype: long
# The time of data node waiting for the next retry to join into the cluster.
@@ -66,9 +66,9 @@ dn_data_region_consensus_port=40010
# For the first ConfigNode to start, cn_target_config_node_list points to its own cn_internal_address:cn_internal_port.
# For other ConfigNodes that to join the cluster, target_config_node_list points to any running ConfigNode's cn_internal_address:cn_internal_port.
-# Format: address:port(,address:port)* e.g. 127.0.0.1:22277,127.0.0.1:22279
+# Format: address:port(,address:port)* e.g. 127.0.0.1:10710,127.0.0.1:10711
# Datatype: String
-dn_target_config_node_list=127.0.0.1:22277
+dn_target_config_node_list=127.0.0.1:10710
####################
### Connection Configuration
diff --git a/server/src/assembly/resources/sbin/start-datanode.bat b/server/src/assembly/resources/sbin/start-datanode.bat
index 7559ad2db8..ea66a36632 100755
--- a/server/src/assembly/resources/sbin/start-datanode.bat
+++ b/server/src/assembly/resources/sbin/start-datanode.bat
@@ -139,10 +139,10 @@ IF EXIST "%IOTDB_CONF%\iotdb-datanode.properties" (
) ELSE (
echo "Can't find iotdb-datanode.properties, check the default ports"
set dn_rpc_port=6667
- set dn_internal_port=9003
- set dn_mpp_data_exchange_port=8777
- set dn_schema_region_consensus_port=50010
- set dn_data_region_consensus_port=40010
+ set dn_internal_port=10730
+ set dn_mpp_data_exchange_port=10740
+ set dn_schema_region_consensus_port=10750
+ set dn_data_region_consensus_port=10760
)
echo Check whether the ports are occupied....
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index acd93765dc..86399b8df3 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -863,17 +863,17 @@ public class IoTDBConfig {
private String internalAddress = "127.0.0.1";
/** Internal port for coordinator */
- private int internalPort = 9003;
+ private int internalPort = 10730;
/** Internal port for dataRegion consensus protocol */
- private int dataRegionConsensusPort = 40010;
+ private int dataRegionConsensusPort = 10760;
/** Internal port for schemaRegion consensus protocol */
- private int schemaRegionConsensusPort = 50010;
+ private int schemaRegionConsensusPort = 10750;
/** Ip and port of config nodes. */
private List<TEndPoint> targetConfigNodeList =
- Collections.singletonList(new TEndPoint("127.0.0.1", 22277));
+ Collections.singletonList(new TEndPoint("127.0.0.1", 10710));
/** The time of data node waiting for the next retry to join into the cluster */
private long joinClusterRetryIntervalMs = TimeUnit.SECONDS.toMillis(5);
@@ -904,7 +904,7 @@ public class IoTDBConfig {
private int seriesPartitionSlotNum = 10000;
/** Port that mpp data exchange thrift service listen to. */
- private int mppDataExchangePort = 8777;
+ private int mppDataExchangePort = 10740;
/** Core pool size of mpp data exchange. */
private int mppDataExchangeCorePoolSize = 10;
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
index b4b4708028..9bb241d73f 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
@@ -1805,7 +1805,7 @@ public class IoTDBDescriptor {
conf.setTargetConfigNodeList(NodeUrlUtils.parseTEndPointUrls(configNodeUrls));
} catch (BadNodeUrlException e) {
logger.error(
- "Config nodes are set in wrong format, please set them like 127.0.0.1:22277,127.0.0.1:22281");
+ "Config nodes are set in wrong format, please set them like 127.0.0.1:10710,127.0.0.1:10712");
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/TestRPCClient.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/TestRPCClient.java
index b9a358c2c3..872e1eb66d 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/TestRPCClient.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/TestRPCClient.java
@@ -66,7 +66,7 @@ public class TestRPCClient {
private void loadSnapshot() {
try (SyncIoTConsensusServiceClient client =
- syncClientManager.borrowClient(new TEndPoint("127.0.0.1", 40011))) {
+ syncClientManager.borrowClient(new TEndPoint("127.0.0.1", 10761))) {
TTriggerSnapshotLoadRes res =
client.triggerSnapshotLoad(
new TTriggerSnapshotLoadReq(
@@ -79,7 +79,7 @@ public class TestRPCClient {
private void testAddPeer() {
try (SyncIoTConsensusServiceClient client =
- syncClientManager.borrowClient(new TEndPoint("127.0.0.1", 40012))) {
+ syncClientManager.borrowClient(new TEndPoint("127.0.0.1", 10762))) {
TInactivatePeerRes res =
client.inactivatePeer(
new TInactivatePeerReq(new DataRegionId(1).convertToTConsensusGroupId()));
@@ -91,7 +91,7 @@ public class TestRPCClient {
private void removeRegionPeer() {
try (SyncDataNodeInternalServiceClient client =
- INTERNAL_SERVICE_CLIENT_MANAGER.borrowClient(new TEndPoint("127.0.0.1", 9003))) {
+ INTERNAL_SERVICE_CLIENT_MANAGER.borrowClient(new TEndPoint("127.0.0.1", 10730))) {
client.removeRegionPeer(
new TMaintainPeerReq(new DataRegionId(1).convertToTConsensusGroupId(), getLocation2(3)));
} catch (Exception e) {
@@ -101,7 +101,7 @@ public class TestRPCClient {
private void addPeer() {
try (SyncDataNodeInternalServiceClient client =
- INTERNAL_SERVICE_CLIENT_MANAGER.borrowClient(new TEndPoint("127.0.0.1", 9003))) {
+ INTERNAL_SERVICE_CLIENT_MANAGER.borrowClient(new TEndPoint("127.0.0.1", 10730))) {
client.addRegionPeer(
new TMaintainPeerReq(new DataRegionId(1).convertToTConsensusGroupId(), getLocation2(3)));
} catch (Exception e) {
@@ -113,25 +113,25 @@ public class TestRPCClient {
return new TDataNodeLocation(
dataNodeId,
new TEndPoint("127.0.0.1", 6669),
- new TEndPoint("127.0.0.1", 9005),
- new TEndPoint("127.0.0.1", 8779),
- new TEndPoint("127.0.0.1", 40012),
- new TEndPoint("127.0.0.1", 50012));
+ new TEndPoint("127.0.0.1", 10732),
+ new TEndPoint("127.0.0.1", 10742),
+ new TEndPoint("127.0.0.1", 10762),
+ new TEndPoint("127.0.0.1", 10752));
}
private TDataNodeLocation getLocation2(int dataNodeId) {
return new TDataNodeLocation(
dataNodeId,
new TEndPoint("127.0.0.1", 6668),
- new TEndPoint("127.0.0.1", 9004),
- new TEndPoint("127.0.0.1", 8778),
- new TEndPoint("127.0.0.1", 40011),
- new TEndPoint("127.0.0.1", 50011));
+ new TEndPoint("127.0.0.1", 10731),
+ new TEndPoint("127.0.0.1", 10741),
+ new TEndPoint("127.0.0.1", 10761),
+ new TEndPoint("127.0.0.1", 10751));
}
private void createDataRegion() {
try (SyncDataNodeInternalServiceClient client =
- INTERNAL_SERVICE_CLIENT_MANAGER.borrowClient(new TEndPoint("127.0.0.1", 9005))) {
+ INTERNAL_SERVICE_CLIENT_MANAGER.borrowClient(new TEndPoint("127.0.0.1", 10732))) {
TCreateDataRegionReq req = new TCreateDataRegionReq();
req.setStorageGroup("root.test.g_0");
TRegionReplicaSet regionReplicaSet = new TRegionReplicaSet();
@@ -141,26 +141,26 @@ public class TestRPCClient {
new TDataNodeLocation(
3,
new TEndPoint("127.0.0.1", 6667),
- new TEndPoint("127.0.0.1", 9003),
- new TEndPoint("127.0.0.1", 8777),
- new TEndPoint("127.0.0.1", 40010),
- new TEndPoint("127.0.0.1", 50010)));
+ new TEndPoint("127.0.0.1", 10730),
+ new TEndPoint("127.0.0.1", 10740),
+ new TEndPoint("127.0.0.1", 10760),
+ new TEndPoint("127.0.0.1", 10750)));
locationList.add(
new TDataNodeLocation(
4,
new TEndPoint("127.0.0.1", 6668),
- new TEndPoint("127.0.0.1", 9004),
- new TEndPoint("127.0.0.1", 8778),
- new TEndPoint("127.0.0.1", 40011),
- new TEndPoint("127.0.0.1", 50011)));
+ new TEndPoint("127.0.0.1", 10731),
+ new TEndPoint("127.0.0.1", 10741),
+ new TEndPoint("127.0.0.1", 10761),
+ new TEndPoint("127.0.0.1", 10751)));
locationList.add(
new TDataNodeLocation(
4,
new TEndPoint("127.0.0.1", 6669),
- new TEndPoint("127.0.0.1", 9005),
- new TEndPoint("127.0.0.1", 8779),
- new TEndPoint("127.0.0.1", 40012),
- new TEndPoint("127.0.0.1", 50012)));
+ new TEndPoint("127.0.0.1", 10732),
+ new TEndPoint("127.0.0.1", 10742),
+ new TEndPoint("127.0.0.1", 10762),
+ new TEndPoint("127.0.0.1", 10752)));
regionReplicaSet.setDataNodeLocations(locationList);
req.setRegionReplicaSet(regionReplicaSet);
TSStatus res = client.createDataRegion(req);
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/FragmentInstanceSerdeTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/FragmentInstanceSerdeTest.java
index 8585732e76..968bc5c61b 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/FragmentInstanceSerdeTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/FragmentInstanceSerdeTest.java
@@ -62,10 +62,10 @@ public class FragmentInstanceSerdeTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
PlanFragmentId planFragmentId = new PlanFragmentId("test", -1);
FragmentInstance fragmentInstance =
@@ -104,10 +104,10 @@ public class FragmentInstanceSerdeTest {
TDataNodeLocation dataNodeLocation = new TDataNodeLocation();
dataNodeLocation.setDataNodeId(0);
dataNodeLocation.setClientRpcEndPoint(new TEndPoint("0.0.0.0", 6667));
- dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 9003));
- dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 8777));
- dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 40010));
- dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 50010));
+ dataNodeLocation.setInternalEndPoint(new TEndPoint("0.0.0.0", 10730));
+ dataNodeLocation.setMPPDataExchangeEndPoint(new TEndPoint("0.0.0.0", 10740));
+ dataNodeLocation.setDataRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10760));
+ dataNodeLocation.setSchemaRegionConsensusEndPoint(new TEndPoint("0.0.0.0", 10750));
PlanFragmentId planFragmentId = new PlanFragmentId("test2", 1);
FragmentInstance fragmentInstance =
diff --git a/server/src/test/resources/datanode1conf/iotdb-datanode.properties b/server/src/test/resources/datanode1conf/iotdb-datanode.properties
index 5bb899e5ba..65c9462931 100644
--- a/server/src/test/resources/datanode1conf/iotdb-datanode.properties
+++ b/server/src/test/resources/datanode1conf/iotdb-datanode.properties
@@ -21,12 +21,12 @@ dn_rpc_address=0.0.0.0
dn_internal_address=127.0.0.1
dn_rpc_port=6667
-dn_mpp_data_exchange_port=8777
-dn_internal_port=9003
-dn_data_region_consensus_port=40010
+dn_mpp_data_exchange_port=10740
+dn_internal_port=10730
+dn_data_region_consensus_port=10760
dn_schema_region_consensus_port=50030
-dn_target_config_node_list=127.0.0.1:22277,127.0.0.1:22279,127.0.0.1:22281
+dn_target_config_node_list=127.0.0.1:10710,127.0.0.1:10711,127.0.0.1:10712
dn_system_dir=target/datanode1/system
dn_data_dirs=target/datanode1/data
diff --git a/server/src/test/resources/datanode2conf/iotdb-datanode.properties b/server/src/test/resources/datanode2conf/iotdb-datanode.properties
index 0daf3bd5dd..065d99ca41 100644
--- a/server/src/test/resources/datanode2conf/iotdb-datanode.properties
+++ b/server/src/test/resources/datanode2conf/iotdb-datanode.properties
@@ -21,12 +21,12 @@ dn_rpc_address=0.0.0.0
dn_internal_address=127.0.0.1
dn_rpc_port=6669
-dn_mpp_data_exchange_port=8779
-dn_internal_port=9005
-dn_data_region_consensus_port=40012
+dn_mpp_data_exchange_port=10742
+dn_internal_port=10732
+dn_data_region_consensus_port=10762
dn_schema_region_consensus_port=50032
-dn_target_config_node_list=127.0.0.1:22277,127.0.0.1:22279,127.0.0.1:22281
+dn_target_config_node_list=127.0.0.1:10710,127.0.0.1:10711,127.0.0.1:10712
dn_system_dir=target/datanode2/system
dn_data_dirs=target/datanode2/data
diff --git a/server/src/test/resources/datanode3conf/iotdb-datanode.properties b/server/src/test/resources/datanode3conf/iotdb-datanode.properties
index 9837d3e26a..3760066f75 100644
--- a/server/src/test/resources/datanode3conf/iotdb-datanode.properties
+++ b/server/src/test/resources/datanode3conf/iotdb-datanode.properties
@@ -26,7 +26,7 @@ dn_internal_port=9007
dn_data_region_consensus_port=40014
dn_schema_region_consensus_port=50034
-dn_target_config_node_list=127.0.0.1:22277,127.0.0.1:22279,127.0.0.1:22281
+dn_target_config_node_list=127.0.0.1:10710,127.0.0.1:10711,127.0.0.1:10712
dn_system_dir=target/datanode3/system
dn_data_dirs=target/datanode3/data
diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/IExpressionOptimizerTest.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/IExpressionOptimizerTest.java
index 2f0a643d25..fd7ba3f3f0 100644
--- a/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/IExpressionOptimizerTest.java
+++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/IExpressionOptimizerTest.java
@@ -217,7 +217,7 @@ public class IExpressionOptimizerTest {
new SingleSeriesExpression(new Path("d1", "s2", true), filter2);
IExpression globalTimeFilter1 = new GlobalTimeExpression(TimeFilter.lt(14001234L));
- IExpression globalTimeFilter2 = new GlobalTimeExpression(TimeFilter.gt(14001000L));
+ IExpression globalTimeFilter2 = new GlobalTimeExpression(TimeFilter.gt(11076000L));
IExpression expression =
BinaryExpression.or(
BinaryExpression.or(singleSeriesExp1, singleSeriesExp2),
@@ -225,10 +225,10 @@ public class IExpressionOptimizerTest {
try {
String rightRet =
- "[[[[d1.s1:(time < 14001234 && time > 14001000)] "
- + "|| [d2.s1:((time < 14001234 && time > 14001000) || (value > 100 || value < 50))]] "
- + "|| [d1.s2:((time < 14001234 && time > 14001000) || (value > 100.5 || value < 50.6))]] "
- + "|| [d2.s2:(time < 14001234 && time > 14001000)]]";
+ "[[[[d1.s1:(time < 14001234 && time > 11076000)] "
+ + "|| [d2.s1:((time < 14001234 && time > 11076000) || (value > 100 || value < 50))]] "
+ + "|| [d1.s2:((time < 14001234 && time > 11076000) || (value > 100.5 || value < 50.6))]] "
+ + "|| [d2.s2:(time < 14001234 && time > 11076000)]]";
IExpression regularFilter = expressionOptimizer.optimize(expression, selectedSeries);
Assert.assertEquals(rightRet, regularFilter.toString());
} catch (QueryFilterOptimizationException e) {
@@ -242,8 +242,8 @@ public class IExpressionOptimizerTest {
try {
String rightRet2 =
- "[[d2.s1:((value > 100 || value < 50) && (time < 14001234 && time > 14001000))] || "
- + "[d1.s2:((value > 100.5 || value < 50.6) && (time < 14001234 && time > 14001000))]]";
+ "[[d2.s1:((value > 100 || value < 50) && (time < 14001234 && time > 11076000))] || "
+ + "[d1.s2:((value > 100.5 || value < 50.6) && (time < 14001234 && time > 11076000))]]";
IExpression regularFilter2 = expressionOptimizer.optimize(expression2, selectedSeries);
Assert.assertEquals(rightRet2, regularFilter2.toString());
} catch (QueryFilterOptimizationException e) {