You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ed...@apache.org on 2024/03/11 13:01:30 UTC
(accumulo) branch 2.1 updated: Change to use ServerContext to get scheduled thread pool (#4353)
This is an automated email from the ASF dual-hosted git repository.
edcoleman pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/2.1 by this push:
new 45bcbd44b9 Change to use ServerContext to get scheduled thread pool (#4353)
45bcbd44b9 is described below
commit 45bcbd44b9ae43a69552d2f1863490e75a376a32
Author: EdColeman <de...@etcoleman.com>
AuthorDate: Mon Mar 11 09:01:24 2024 -0400
Change to use ServerContext to get scheduled thread pool (#4353)
---
.../src/main/java/org/apache/accumulo/manager/ManagerTime.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/server/manager/src/main/java/org/apache/accumulo/manager/ManagerTime.java b/server/manager/src/main/java/org/apache/accumulo/manager/ManagerTime.java
index c7eac43ff0..8bd842fc9d 100644
--- a/server/manager/src/main/java/org/apache/accumulo/manager/ManagerTime.java
+++ b/server/manager/src/main/java/org/apache/accumulo/manager/ManagerTime.java
@@ -64,10 +64,9 @@ public class ManagerTime {
throw new IOException("Error updating manager time", ex);
}
- ThreadPools.watchCriticalScheduledTask(
- ThreadPools.getServerThreadPools().createGeneralScheduledExecutorService(conf)
- .scheduleWithFixedDelay(Threads.createNamedRunnable("Manager time keeper", () -> run()),
- 0, SECONDS.toMillis(10), MILLISECONDS));
+ ThreadPools.watchCriticalScheduledTask(manager.getContext().getScheduledExecutor()
+ .scheduleWithFixedDelay(Threads.createNamedRunnable("Manager time keeper", () -> run()), 0,
+ SECONDS.toMillis(10), MILLISECONDS));
}
/**