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 b49226d1b57 HDDS-14860. Synchronize ThrottledAsyncChecker#schedule
(#9948)
b49226d1b57 is described below
commit b49226d1b574ea99cda195b28a0368d6f2ae9e8b
Author: Rishabh Patel <[email protected]>
AuthorDate: Thu Mar 19 07:31:10 2026 -0700
HDDS-14860. Synchronize ThrottledAsyncChecker#schedule (#9948)
---
.../hadoop/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 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<ListenableFuture<V>> schedule(
+ public synchronized Optional<ListenableFuture<V>> schedule(
Checkable<K, V> target, K context) {
if (checksInProgress.containsKey(target)) {
return Optional.empty();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
