Skip to content

Commit d688f9b

Browse files
Close RemoteStorePinnedTimestampService on Node.close() (#16228)
Signed-off-by: Sachin Kale <[email protected]> (cherry picked from commit 96082f7) Signed-off-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
1 parent ad97686 commit d688f9b

File tree

1 file changed

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

1 file changed

+2
-0
lines changed

Diff for: server/src/main/java/org/opensearch/node/Node.java

+2
Original file line numberDiff line numberDiff line change
@@ -1862,6 +1862,7 @@ public synchronized void close() throws IOException {
18621862
toClose.add(() -> stopWatch.stop().start("transport"));
18631863
toClose.add(injector.getInstance(TransportService.class));
18641864
toClose.add(nodeService.getTaskCancellationMonitoringService());
1865+
toClose.add(injector.getInstance(RemoteStorePinnedTimestampService.class));
18651866

18661867
for (LifecycleComponent plugin : pluginLifecycleComponents) {
18671868
toClose.add(() -> stopWatch.stop().start("plugin(" + plugin.getClass().getName() + ")"));
@@ -1892,6 +1893,7 @@ public synchronized void close() throws IOException {
18921893
if (logger.isTraceEnabled()) {
18931894
toClose.add(() -> logger.trace("Close times for each service:\n{}", stopWatch.prettyPrint()));
18941895
}
1896+
18951897
IOUtils.close(toClose);
18961898
logger.info("closed");
18971899
}

0 commit comments

Comments
 (0)