This is an automated email from the ASF dual-hosted git repository.
ChenSammi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 0f811d443ce HDDS-15127. Add a switch to toggle the RocksDb open test
for volume health (#10149)
0f811d443ce is described below
commit 0f811d443ce260cb7c2dd4adb0977dada1ac0456
Author: Rishabh Patel <[email protected]>
AuthorDate: Wed May 6 23:02:02 2026 -0700
HDDS-15127. Add a switch to toggle the RocksDb open test for volume health
(#10149)
---
.../container/common/statemachine/DatanodeConfiguration.java | 12 ++++++++++++
.../hadoop/ozone/container/common/volume/HddsVolume.java | 2 +-
2 files changed, 13 insertions(+), 1 deletion(-)
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/DatanodeConfiguration.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/DatanodeConfiguration.java
index 919777f3519..a477e3876a1 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/DatanodeConfiguration.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/DatanodeConfiguration.java
@@ -384,6 +384,14 @@ public class DatanodeConfiguration extends
ReconfigurableConfig {
)
private boolean isDiskCheckEnabled = true;
+ @Config(key = "hdds.datanode.disk.check.rocksdb.check.io.test.enabled",
+ defaultValue = "true",
+ type = ConfigType.BOOLEAN,
+ tags = {DATANODE},
+ description = "The configuration to enable or disable RocksDb disk IO
checks."
+ )
+ private boolean isRocksDbDiskCheckEnabled = true;
+
@Config(key = "hdds.datanode.disk.check.io.failures.tolerated",
defaultValue = "1",
type = ConfigType.INT,
@@ -1013,6 +1021,10 @@ public boolean isDiskCheckEnabled() {
return isDiskCheckEnabled;
}
+ public boolean isRocksDbDiskCheckEnabled() {
+ return isRocksDbDiskCheckEnabled;
+ }
+
public Duration getDiskCheckSlidingWindowTimeout() {
return diskCheckSlidingWindowTimeout;
}
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/HddsVolume.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/HddsVolume.java
index 310c46de529..8ac48fae748 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/HddsVolume.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/HddsVolume.java
@@ -306,7 +306,7 @@ public synchronized VolumeCheckResult check(@Nullable
Boolean unused)
@VisibleForTesting
public VolumeCheckResult checkDbHealth(File dbFile) throws
InterruptedException {
- if (!getDiskCheckEnabled()) {
+ if (!(getDiskCheckEnabled() &&
getDatanodeConfig().isRocksDbDiskCheckEnabled())) {
return VolumeCheckResult.HEALTHY;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
