diff --git a/server/src/main/java/io/druid/server/initialization/jetty/JettyServerModule.java b/server/src/main/java/io/druid/server/initialization/jetty/JettyServerModule.java index 08d1e01e03d2..45bd177251b0 100644 --- a/server/src/main/java/io/druid/server/initialization/jetty/JettyServerModule.java +++ b/server/src/main/java/io/druid/server/initialization/jetty/JettyServerModule.java @@ -51,6 +51,7 @@ import org.eclipse.jetty.server.Server; import org.eclipse.jetty.server.ServerConnector; import org.eclipse.jetty.util.thread.QueuedThreadPool; +import org.eclipse.jetty.util.thread.ScheduledExecutorScheduler; import javax.servlet.ServletException; import java.util.Map; @@ -161,6 +162,10 @@ private static Server makeJettyServer(@Self DruidNode node, ServerConfig config) final Server server = new Server(threadPool); + // Without this bean set, the default ScheduledExecutorScheduler runs as non-daemon, causing lifecycle hooks to fail + // to fire on main exit. Related bug: https://github.com/druid-io/druid/pull/1627 + server.addBean(new ScheduledExecutorScheduler("JettyScheduler", true), true); + ServerConnector connector = new ServerConnector(server); connector.setPort(node.getPort()); connector.setIdleTimeout(Ints.checkedCast(config.getMaxIdleTime().toStandardDuration().getMillis()));