Skip to content

Commit 96082f7

Browse files
authored
Close RemoteStorePinnedTimestampService on Node.close() (#16228)
Signed-off-by: Sachin Kale <[email protected]>
1 parent aad325f commit 96082f7

File tree

1 file changed

+2
-0
lines changed
  • server/src/main/java/org/opensearch/node

1 file changed

+2
-0
lines changed

server/src/main/java/org/opensearch/node/Node.java

+2
Original file line numberDiff line numberDiff line change
@@ -1868,6 +1868,7 @@ public synchronized void close() throws IOException {
18681868
toClose.add(() -> stopWatch.stop().start("transport"));
18691869
toClose.add(injector.getInstance(TransportService.class));
18701870
toClose.add(nodeService.getTaskCancellationMonitoringService());
1871+
toClose.add(injector.getInstance(RemoteStorePinnedTimestampService.class));
18711872

18721873
for (LifecycleComponent plugin : pluginLifecycleComponents) {
18731874
toClose.add(() -> stopWatch.stop().start("plugin(" + plugin.getClass().getName() + ")"));
@@ -1898,6 +1899,7 @@ public synchronized void close() throws IOException {
18981899
if (logger.isTraceEnabled()) {
18991900
toClose.add(() -> logger.trace("Close times for each service:\n{}", stopWatch.prettyPrint()));
19001901
}
1902+
19011903
IOUtils.close(toClose);
19021904
logger.info("closed");
19031905
}

0 commit comments

Comments
 (0)