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 9e023a74127..6cb0679e3cc 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();