From d8a826520b7c3726c43af89706654b8b2b3fff1a Mon Sep 17 00:00:00 2001 From: Rishabh Patel Date: Wed, 18 Mar 2026 13:40:12 -0700 Subject: [PATCH] HDDS-14860. Synchronize `schedule` method in ThrottledAsyncChecker to ensure thread safety. --- .../ozone/container/common/volume/ThrottledAsyncChecker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/ThrottledAsyncChecker.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/ThrottledAsyncChecker.java index 9e023a74127f..6cb0679e3cc3 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/ThrottledAsyncChecker.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/volume/ThrottledAsyncChecker.java @@ -115,7 +115,7 @@ public ThrottledAsyncChecker(final Timer timer, * will receive the same Future. */ @Override - public Optional> schedule( + public synchronized Optional> schedule( Checkable target, K context) { if (checksInProgress.containsKey(target)) { return Optional.empty();