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/10/21 14:23:31 UTC
[iotdb] branch master updated: [IOTDB-4711] Bind DataNodeInternalService to correct address (#7683)
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new aabb052dca [IOTDB-4711] Bind DataNodeInternalService to correct address (#7683)
aabb052dca is described below
commit aabb052dca2bbab204ef4bb0c76848d3cedc3d65
Author: YongzaoDan <33...@users.noreply.github.com>
AuthorDate: Fri Oct 21 22:23:23 2022 +0800
[IOTDB-4711] Bind DataNodeInternalService to correct address (#7683)
---
.../iotdb/db/mpp/plan/execution/config/metadata/ShowClusterTask.java | 4 ++--
.../java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowClusterTask.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowClusterTask.java
index 50b6d3fa85..80612cfd53 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowClusterTask.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/ShowClusterTask.java
@@ -97,8 +97,8 @@ public class ShowClusterTask implements IConfigTask {
e.getDataNodeId(),
NODE_TYPE_DATA_NODE,
clusterNodeInfos.getNodeStatus().get(e.getDataNodeId()),
- e.getInternalEndPoint().getIp(),
- e.getInternalEndPoint().getPort()));
+ e.getClientRpcEndPoint().getIp(),
+ e.getClientRpcEndPoint().getPort()));
DatasetHeader datasetHeader = DatasetHeaderFactory.getShowClusterHeader();
future.set(new ConfigTaskResult(TSStatusCode.SUCCESS_STATUS, builder.build(), datasetHeader));
diff --git a/server/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java b/server/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java
index 78d1761271..f0f7e941db 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/DataNodeInternalRPCService.java
@@ -78,7 +78,7 @@ public class DataNodeInternalRPCService extends ThriftService
@Override
public String getBindIP() {
- return IoTDBDescriptor.getInstance().getConfig().getRpcAddress();
+ return IoTDBDescriptor.getInstance().getConfig().getInternalAddress();
}
@Override