You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2023/09/18 12:41:50 UTC
[iotdb] branch rel/1.2 updated: fix (#11165)
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr 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 1699f7424f7 fix (#11165)
1699f7424f7 is described below
commit 1699f7424f7f3e1f03d2d50d82dcd81ed29961b4
Author: Potato <ta...@apache.org>
AuthorDate: Mon Sep 18 20:41:43 2023 +0800
fix (#11165)
---
.../iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 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 0ba27aac9c6..cd3193f1abb 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
@@ -1302,8 +1302,8 @@ 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)) {
+ } else if (NodeStatus.ReadOnly.equals(commonConfig.getNodeStatus())
+ && NodeStatus.DISK_FULL.equals(commonConfig.getStatusReason())) {
commonConfig.setNodeStatus(NodeStatus.Running);
commonConfig.setStatusReason(null);
}