You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/10/18 12:10:12 UTC
[iotdb] 01/01: [IOTDB-4679] Make MPPDataExchangeService use internal_address instead of rpc_address
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch MPPDataExchangeIPBug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 0ddae1ce3c784bccce6ad7447eb93a5ac6e4cfb6
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Oct 18 20:09:58 2022 +0800
[IOTDB-4679] Make MPPDataExchangeService use internal_address instead of rpc_address
---
.../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