(iotdb) branch dev/1.3 updated: Pipe: Do not stop runtime agent when removing datanode (#14474) (#14475)

[rong]

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

rong pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 4fe2353a98e Pipe: Do not stop runtime agent when removing datanode 
(#14474) (#14475)
4fe2353a98e is described below

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

    Pipe: Do not stop runtime agent when removing datanode (#14474) (#14475)
---
 .../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 a8cd3f4c54b..b3544644bf4 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
@@ -1897,9 +1897,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());
     }