This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new dbdc4b43cd2 fix confignode start (#16527)
dbdc4b43cd2 is described below
commit dbdc4b43cd27e1ec026c7b1816757e5bab9b18b8
Author: shuwenwei <[email protected]>
AuthorDate: Tue Sep 30 06:30:41 2025 +0800
fix confignode start (#16527)
---
.../client/async/CnToDnInternalServiceAsyncRequestManager.java | 4 ++++
.../db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java | 5 +++++
iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift | 5 +++++
3 files changed, 14 insertions(+)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/CnToDnInternalServiceAsyncRequestManager.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/CnToDnInternalServiceAsyncRequestManager.java
index d23e14728dc..8ccd0104eb9 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/CnToDnInternalServiceAsyncRequestManager.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/CnToDnInternalServiceAsyncRequestManager.java
@@ -470,6 +470,10 @@ public class CnToDnInternalServiceAsyncRequestManager
CnToDnAsyncRequestType.STOP_AND_CLEAR_DATA_NODE,
(req, client, handler) ->
client.stopAndClearDataNode((DataNodeTSStatusRPCHandler) handler));
+ actionMapBuilder.put(
+ CnToDnAsyncRequestType.ENABLE_SEPARATION_OF_ADMIN_POWERS,
+ (req, client, handler) ->
+ client.enableSeparationOfAdminPower((DataNodeTSStatusRPCHandler)
handler));
}
@Override
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java
index 433497657e7..ed199001ef8 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java
@@ -2291,6 +2291,11 @@ public class DataNodeInternalRPCServiceImpl implements
IDataNodeRPCService.Iface
return RpcUtils.getStatus(TSStatusCode.CLEAR_PERMISSION_CACHE_ERROR);
}
+ @Override
+ public TSStatus enableSeparationOfAdminPower() throws TException {
+ return null;
+ }
+
@Override
public TSStatus merge() throws TException {
try {
diff --git a/iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
b/iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
index f142928deb2..1086b5b8acd 100644
--- a/iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
+++ b/iotdb-protocol/thrift-datanode/src/main/thrift/datanode.thrift
@@ -982,6 +982,11 @@ service IDataNodeRPCService {
*/
common.TSStatus invalidatePermissionCache(TInvalidatePermissionCacheReq req)
+ /**
+ * Enable separation of admin powers in datanode
+ **/
+ common.TSStatus enableSeparationOfAdminPower()
+
/**
* Config node will create a pipe plugin on a list of data nodes.
*