This is an automated email from the ASF dual-hosted git repository.
adoroszlai 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 c7872f7d65 HDDS-12162. Log available space of HddsVolume and DbVolume
upon Datanode startup (#7777)
c7872f7d65 is described below
commit c7872f7d655aac5f5a2fba0b37e662a543531d30
Author: Siyao Meng <[email protected]>
AuthorDate: Thu Jan 30 00:14:30 2025 -0800
HDDS-12162. Log available space of HddsVolume and DbVolume upon Datanode
startup (#7777)
---
.../src/main/java/org/apache/hadoop/hdds/fs/SpaceUsageSource.java | 5 +++++
.../org/apache/hadoop/ozone/container/common/volume/DbVolume.java | 4 ++--
.../apache/hadoop/ozone/container/common/volume/HddsVolume.java | 7 ++++---
3 files changed, 11 insertions(+), 5 deletions(-)
diff --git
a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/fs/SpaceUsageSource.java
b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/fs/SpaceUsageSource.java
index a367cfbdc0..46fd76b8bd 100644
---
a/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/fs/SpaceUsageSource.java
+++
b/hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/fs/SpaceUsageSource.java
@@ -82,5 +82,10 @@ public long getUsedSpace() {
public SpaceUsageSource snapshot() {
return this; // immutable
}
+
+ @Override
+ public String toString() {
+ return "capacity=" + capacity + ", used=" + used + ", available=" +
available;
+ }
}
}
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/DbVolume.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/DbVolume.java
index 2a762b2387..ac5da4d176 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/DbVolume.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/DbVolume.java
@@ -57,9 +57,9 @@ protected DbVolume(Builder b) throws IOException {
this.hddsDbStorePathMap = new HashMap<>();
if (!b.getFailedVolume() && getVolumeInfo().isPresent()) {
- LOG.info("Creating DbVolume: {} of storage type : {} capacity : {}",
+ LOG.info("Creating DbVolume: {} of storage type: {}, {}",
getStorageDir(), b.getStorageType(),
- getVolumeInfo().get().getCapacity());
+ getCurrentUsage());
initialize();
}
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 5fced0e39b..b48fed963c 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
@@ -131,9 +131,10 @@ private HddsVolume(Builder b) throws IOException {
this.volumeInfoMetrics =
new VolumeInfoMetrics(b.getVolumeRootStr(), this);
- LOG.info("Creating HddsVolume: {} of storage type : {} capacity : {}",
- getStorageDir(), b.getStorageType(),
- getVolumeInfo().get().getCapacity());
+ LOG.info("Creating HddsVolume: {} of storage type: {}, {}",
+ getStorageDir(),
+ b.getStorageType(),
+ getCurrentUsage());
initialize();
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
