(iotdb) branch master updated: Pipe: Do not stop runtime agent when removing datanode (#14474)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong 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 addbf964e4a Pipe: Do not stop runtime agent when removing datanode 
(#14474)
addbf964e4a is described below

commit addbf964e4af1861e6516d7ec7899f3a29311b59
Author: Peng Junzhi <78788603+peng...@users.noreply.github.com>
AuthorDate: Tue Dec 17 23:58:40 2024 +0800

    Pipe: Do not stop runtime agent when removing datanode (#14474)
---
 .../iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java  | 3 ---
 1 file changed, 3 deletions(-)

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 1e9f30a2dec..90635c1e029 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
@@ -2183,9 +2183,6 @@ public class DataNodeInternalRPCServiceImpl implements 
IDataNodeRPCService.Iface
   public TSStatus setSystemStatus(String status) throws TException {
     try {
       commonConfig.setNodeStatus(NodeStatus.parse(status));
-      if (commonConfig.getNodeStatus().equals(NodeStatus.Removing)) {
-        PipeDataNodeAgent.runtime().stop();
-      }
     } catch (Exception e) {
       return RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, 
e.getMessage());
     }