Close RemoteStorePinnedTimestampService on Node.close() (opensearch-p…

…roject#16228) Signed-off-by: Sachin Kale <[email protected]>
dk2k · Oct 16, 2024 · 53f2aac · 53f2aac
1 parent 8a5c6f3
commit 53f2aac
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/server/src/main/java/org/opensearch/node/Node.java b/server/src/main/java/org/opensearch/node/Node.java
@@ -1868,6 +1868,7 @@ public synchronized void close() throws IOException {
  toClose.add(() -> stopWatch.stop().start("transport"));
  toClose.add(injector.getInstance(TransportService.class));
  toClose.add(nodeService.getTaskCancellationMonitoringService());
+ toClose.add(injector.getInstance(RemoteStorePinnedTimestampService.class));
 
  for (LifecycleComponent plugin : pluginLifecycleComponents) {
  toClose.add(() -> stopWatch.stop().start("plugin(" + plugin.getClass().getName() + ")"));
@@ -1898,6 +1899,7 @@ public synchronized void close() throws IOException {
  if (logger.isTraceEnabled()) {
  toClose.add(() -> logger.trace("Close times for each service:\n{}", stopWatch.prettyPrint()));
  }
+
  IOUtils.close(toClose);
  logger.info("closed");
  }