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/05/31 06:01:29 UTC
[iotdb] 01/01: Make DataNode start DataNodeTSIServiceImpl RPC service
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 <ja...@gmail.com>
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();