This is an automated email from the ASF dual-hosted git repository. critas pushed a commit to branch wx_address_cp in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6e7ee2c8a4ea04569e3e8b3c578e4adb168a780a Author: CritasWang <[email protected]> AuthorDate: Tue Nov 11 10:44:50 2025 +0800 chore!: Bind real config address for Thrift and Raft services (#16717) * chore: Bind real internal address for Thrift and Raft services * keep ExternalRpcAddress use config value * Update iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/ExternalRPCService.java Co-authored-by: Haonan <[email protected]> --------- Co-authored-by: Haonan <[email protected]> --- .../java/org/apache/iotdb/consensus/ratis/RatisConsensus.java | 1 + .../apache/iotdb/commons/service/AbstractThriftServiceThread.java | 8 ++++++++ 2 files changed, 9 insertions(+) diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java index 384730a9742..20c30922432 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java @@ -156,6 +156,7 @@ class RatisConsensus implements IConsensus { this.storageDir = new File(config.getStorageDir()); RaftServerConfigKeys.setStorageDir(properties, Collections.singletonList(storageDir)); + GrpcConfigKeys.Server.setHost(properties, config.getThisNodeEndPoint().getIp()); GrpcConfigKeys.Server.setPort(properties, config.getThisNodeEndPoint().getPort()); Utils.initRatisConfig(properties, config.getRatisConfig()); diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java index 171942d8610..0da0a92e379 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/AbstractThriftServiceThread.java @@ -283,11 +283,19 @@ public abstract class AbstractThriftServiceThread extends Thread { @SuppressWarnings("java:S2259") private TServerTransport openTransport(String bindAddress, int port) throws TTransportException { + if (bindAddress == null) { + // bind any address + return new TServerSocket(new InetSocketAddress(port)); + } return new TServerSocket(new InetSocketAddress(bindAddress, port)); } private TServerTransport openNonblockingTransport( String bindAddress, int port, int connectionTimeoutInMS) throws TTransportException { + if (bindAddress == null) { + // bind any address + return new TNonblockingServerSocket(new InetSocketAddress(port), connectionTimeoutInMS); + } return new TNonblockingServerSocket( new InetSocketAddress(bindAddress, port), connectionTimeoutInMS); }
