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 <d...@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));
}
/**
