This is an automated email from the ASF dual-hosted git repository.
peterxcli 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 c21e7df49a2 HDDS-15346. DiskBalancer should update delta sizes
atomically. (#10333)
c21e7df49a2 is described below
commit c21e7df49a2ec49d66933f729542504d8c901083
Author: slfan1989 <[email protected]>
AuthorDate: Sun May 24 23:39:25 2026 +0800
HDDS-15346. DiskBalancer should update delta sizes atomically. (#10333)
Co-authored-by: Peter Lee <[email protected]>
---
.../hadoop/ozone/container/diskbalancer/DiskBalancerService.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/diskbalancer/DiskBalancerService.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/diskbalancer/DiskBalancerService.java
index 70d3e8598d4..53470ef0410 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/diskbalancer/DiskBalancerService.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/diskbalancer/DiskBalancerService.java
@@ -443,8 +443,7 @@ public BackgroundTaskQueue getTasks() {
destVolume);
queue.add(task);
inProgressContainers.add(ContainerID.valueOf(toBalanceContainer.getContainerID()));
- deltaSizes.put(sourceVolume, deltaSizes.getOrDefault(sourceVolume,
0L)
- - toBalanceContainer.getBytesUsed());
+ deltaSizes.merge(sourceVolume, -toBalanceContainer.getBytesUsed(),
Long::sum);
}
}
}
@@ -654,8 +653,7 @@ public int getPriority() {
private void postCall(boolean success, long startTime) {
inProgressContainers.remove(ContainerID.valueOf(containerData.getContainerID()));
- deltaSizes.put(sourceVolume, deltaSizes.get(sourceVolume) +
- containerData.getBytesUsed());
+ deltaSizes.merge(sourceVolume, containerData.getBytesUsed(), Long::sum);
destVolume.incCommittedBytes(0 - containerData.getBytesUsed());
long endTime = Time.monotonicNow();
if (success) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
