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

tanxinyu pushed a commit to branch rel/1.2
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/1.2 by this push:
     new 2b8c1b46fc7 [IOTDB-6082] Improve disk space metrics (#10983) (#10987)
2b8c1b46fc7 is described below

commit 2b8c1b46fc775925d007b5f83915e3047cb7aad6
Author: Xiangpeng Hu <[email protected]>
AuthorDate: Tue Aug 29 19:39:57 2023 +0800

    [IOTDB-6082] Improve disk space metrics (#10983) (#10987)
---
 .../iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java | 4 ++++
 1 file changed, 4 insertions(+)

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 ce5cbe6d15c..80589eacb39 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
@@ -1300,6 +1300,10 @@ public class DataNodeInternalRPCServiceImpl implements 
IDataNodeRPCService.Iface
             commonConfig.getDiskSpaceWarningThreshold());
         commonConfig.setNodeStatus(NodeStatus.ReadOnly);
         commonConfig.setStatusReason(NodeStatus.DISK_FULL);
+      } else if (commonConfig.getNodeStatus().equals(NodeStatus.ReadOnly)
+          && commonConfig.getStatusReason().equals(NodeStatus.DISK_FULL)) {
+        commonConfig.setNodeStatus(NodeStatus.Running);
+        commonConfig.setStatusReason(null);
       }
     }
   }

Reply via email to