You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/10/19 01:55:49 UTC
[iotdb] branch master updated: [IOTDB-4679] Make MPPDataExchangeService use internal_address instead of rpc_address (#7648)
This is an automated email from the ASF dual-hosted git repository.
haonan 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 993782d2de [IOTDB-4679] Make MPPDataExchangeService use internal_address instead of rpc_address (#7648)
993782d2de is described below
commit 993782d2def4a4ad8d1e6dbbd7d811222b9b9e99
Author: Jackie Tien <ja...@gmail.com>
AuthorDate: Wed Oct 19 09:55:42 2022 +0800
[IOTDB-4679] Make MPPDataExchangeService use internal_address instead of rpc_address (#7648)
---
.../iotdb/db/mpp/execution/exchange/MPPDataExchangeService.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeService.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeService.java
index 4a0d35cbf4..09d3d3e54b 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeService.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeService.java
@@ -75,8 +75,7 @@ public class MPPDataExchangeService extends ThriftService implements MPPDataExch
}
@Override
- public void initTProcessor()
- throws ClassNotFoundException, IllegalAccessException, InstantiationException {
+ public void initTProcessor() {
initSyncedServiceImpl(null);
processor = new Processor<>(mppDataExchangeManager.getOrCreateMPPDataExchangeServiceImpl());
}
@@ -86,8 +85,7 @@ public class MPPDataExchangeService extends ThriftService implements MPPDataExch
}
@Override
- public void initThriftServiceThread()
- throws IllegalAccessException, InstantiationException, ClassNotFoundException {
+ public void initThriftServiceThread() throws IllegalAccessException {
try {
IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
thriftServiceThread =
@@ -112,7 +110,7 @@ public class MPPDataExchangeService extends ThriftService implements MPPDataExch
@Override
public String getBindIP() {
- return IoTDBDescriptor.getInstance().getConfig().getRpcAddress();
+ return IoTDBDescriptor.getInstance().getConfig().getInternalAddress();
}
@Override