This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch fix_startup_error_log in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9b6daa63c408ac73f2a54d65e6a6add1711be322 Author: HTHou <[email protected]> AuthorDate: Wed Aug 9 16:59:53 2023 +0800 Fix error log when start confignode and datanode --- .../iotdb/confignode/service/thrift/ConfigNodeRPCService.java | 4 ++-- .../iotdb/consensus/iot/service/IoTConsensusRPCService.java | 8 ++++++-- .../apache/iotdb/commons/client/mock/MockInternalRPCService.java | 4 ++-- 3 files changed, 10 insertions(+), 6 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCService.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCService.java index 824b02b3e23..b7840338101 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCService.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCService.java @@ -49,9 +49,9 @@ public class ConfigNodeRPCService extends ThriftService implements ConfigNodeRPC this.configNodeRPCServiceProcessor = (ConfigNodeRPCServiceProcessor) configNodeRPCServerProcessor; + String packageName = this.getClass().getPackage().toString().split(",")[0]; super.mbeanName = - String.format( - "%s:%s=%s", this.getClass().getPackage(), IoTDBConstant.JMX_TYPE, getID().getJmxName()); + String.format("%s:%s=%s", packageName, IoTDBConstant.JMX_TYPE, getID().getJmxName()); super.initSyncedServiceImpl(this.configNodeRPCServiceProcessor); } diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCService.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCService.java index f80a0b8162c..578af535143 100644 --- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCService.java +++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/iot/service/IoTConsensusRPCService.java @@ -30,11 +30,15 @@ import org.apache.iotdb.consensus.config.IoTConsensusConfig; import org.apache.iotdb.consensus.iot.thrift.IoTConsensusIService; import org.apache.thrift.TBaseAsyncProcessor; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.lang.reflect.InvocationTargetException; public class IoTConsensusRPCService extends ThriftService implements IoTConsensusRPCServiceMBean { + private static final Logger logger = LoggerFactory.getLogger(IoTConsensusRPCService.class); + private final TEndPoint thisNode; private final IoTConsensusConfig config; private IoTConsensusRPCServiceProcessor iotConsensusRPCServiceProcessor; @@ -53,9 +57,9 @@ public class IoTConsensusRPCService extends ThriftService implements IoTConsensu public void initAsyncedServiceImpl(Object iotConsensusRPCServiceProcessor) { this.iotConsensusRPCServiceProcessor = (IoTConsensusRPCServiceProcessor) iotConsensusRPCServiceProcessor; + String packageName = this.getClass().getPackage().toString().split(",")[0]; super.mbeanName = - String.format( - "%s:%s=%s", this.getClass().getPackage(), IoTDBConstant.JMX_TYPE, getID().getJmxName()); + String.format("%s:%s=%s", packageName, IoTDBConstant.JMX_TYPE, getID().getJmxName()); super.initAsyncedServiceImpl(this.iotConsensusRPCServiceProcessor); } diff --git a/iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCService.java b/iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCService.java index c4a6b4d3cc0..d3141eb2cb3 100644 --- a/iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCService.java +++ b/iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/mock/MockInternalRPCService.java @@ -49,9 +49,9 @@ public class MockInternalRPCService extends ThriftService implements MockInterna @Override public void initSyncedServiceImpl(Object mockedProcessor) { this.mockedProcessor = (IDataNodeRPCService.Iface) mockedProcessor; + String packageName = this.getClass().getPackage().toString().split(",")[0]; super.mbeanName = - String.format( - "%s:%s=%s", this.getClass().getPackage(), IoTDBConstant.JMX_TYPE, getID().getJmxName()); + String.format("%s:%s=%s", packageName, IoTDBConstant.JMX_TYPE, getID().getJmxName()); super.initSyncedServiceImpl(this.mockedProcessor); }
