This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch DataNodeTSIServiceImpl in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ba4f357020ee7b7989cc44160e28b8170aeac307 Author: JackieTien97 <[email protected]> AuthorDate: Tue May 31 14:01:14 2022 +0800 Make DataNode start DataNodeTSIServiceImpl RPC service --- server/src/main/java/org/apache/iotdb/db/service/DataNode.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/service/DataNode.java b/server/src/main/java/org/apache/iotdb/db/service/DataNode.java index cd4ca1ccad..71528067fb 100644 --- a/server/src/main/java/org/apache/iotdb/db/service/DataNode.java +++ b/server/src/main/java/org/apache/iotdb/db/service/DataNode.java @@ -266,10 +266,16 @@ public class DataNode implements DataNodeMBean { Runtime.getRuntime().addShutdownHook(new IoTDBShutdownHook()); setUncaughtExceptionHandler(); initServiceProvider(); + + // init rpc service + IoTDBDescriptor.getInstance() + .getConfig() + .setRpcImplClassName(DataNodeTSIServiceImpl.class.getName()); // in cluster mode, RPC service is not enabled. if (IoTDBDescriptor.getInstance().getConfig().isEnableRpcService()) { registerManager.register(RPCService.getInstance()); } + registerManager.register(MetricsService.getInstance()); logger.info("recover the schema..."); initConfigManager(); @@ -284,9 +290,6 @@ public class DataNode implements DataNodeMBean { registerManager.register(StorageEngineV2.getInstance()); registerManager.register(DataBlockService.getInstance()); registerManager.register(DriverScheduler.getInstance()); - IoTDBDescriptor.getInstance() - .getConfig() - .setRpcImplClassName(DataNodeTSIServiceImpl.class.getName()); registerUdfServices();
