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 ce5cbe6d15c7b63e513fdd8edaad1d7983affc81..80589eacb39a956e802c209cab1e78073875c7d3 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); } } }