From b331fb4a83dae2bb3c4322f0f2a48abf6face019 Mon Sep 17 00:00:00 2001 From: Gian Merlino Date: Thu, 25 Feb 2016 14:47:15 -0800 Subject: [PATCH] Fix parsing of druid.indexer.server.maxChatRequests. --- .../server/initialization/jetty/ChatHandlerServerModule.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/io/druid/server/initialization/jetty/ChatHandlerServerModule.java b/server/src/main/java/io/druid/server/initialization/jetty/ChatHandlerServerModule.java index fdc17ea4a1c..b7147b25f54 100644 --- a/server/src/main/java/io/druid/server/initialization/jetty/ChatHandlerServerModule.java +++ b/server/src/main/java/io/druid/server/initialization/jetty/ChatHandlerServerModule.java @@ -57,7 +57,7 @@ public class ChatHandlerServerModule implements Module Jerseys.addResource(binder, ChatHandlerResource.class); if (properties.containsKey(MAX_CHAT_REQUESTS_PROPERTY)) { - final int maxRequests = Integer.parseInt(MAX_CHAT_REQUESTS_PROPERTY); + final int maxRequests = Integer.parseInt(properties.getProperty(MAX_CHAT_REQUESTS_PROPERTY)); JettyBindings.addQosFilter(binder, "/druid/worker/v1/chat/*", maxRequests); }