Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Limit number of jetty threads that can be used by lookups (#3068)

This commit is contained in:
Charles Allen 2016-06-02 22:33:12 -07:00 committed by Fangjin Yang
parent 6171e078c8
commit bbc5509078
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/src/main/java/io/druid/query/lookup/LookupModule.java
View File

@ -47,6 +47,7 @@ import io.druid.guice.annotations.Smile;
import io.druid.initialization.DruidModule; import io.druid.initialization.DruidModule;
import io.druid.server.DruidNode; import io.druid.server.DruidNode;
import io.druid.server.initialization.ZkPathsConfig; import io.druid.server.initialization.ZkPathsConfig;
import io.druid.server.initialization.jetty.JettyBindings;
import io.druid.server.listener.announcer.ListenerResourceAnnouncer; import io.druid.server.listener.announcer.ListenerResourceAnnouncer;
import io.druid.server.listener.announcer.ListeningAnnouncerConfig; import io.druid.server.listener.announcer.ListeningAnnouncerConfig;
import io.druid.server.listener.resource.AbstractListenerHandler; import io.druid.server.listener.resource.AbstractListenerHandler;
@ -88,6 +89,11 @@ public class LookupModule implements DruidModule
LifecycleModule.register(binder, LookupResourceListenerAnnouncer.class); LifecycleModule.register(binder, LookupResourceListenerAnnouncer.class);
// Nothing else starts this, so we bind it to get it to start // Nothing else starts this, so we bind it to get it to start
binder.bind(LookupResourceListenerAnnouncer.class).in(ManageLifecycle.class); binder.bind(LookupResourceListenerAnnouncer.class).in(ManageLifecycle.class);
JettyBindings.addQosFilter(
binder,
ListenerResource.BASE_PATH + "/" + LookupCoordinatorManager.LOOKUP_LISTEN_ANNOUNCE_KEY,
2 // 1 for "normal" operation and 1 for "emergency" or other
);
} }
} }