From 41bba4114b790a387088e995fae29c768deca64b Mon Sep 17 00:00:00 2001 From: Gian Merlino Date: Tue, 26 Sep 2017 10:52:52 -0700 Subject: [PATCH] Fix Router handling of SQL queries. --- .../java/io/druid/server/AsyncQueryForwardingServlet.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/server/src/main/java/io/druid/server/AsyncQueryForwardingServlet.java b/server/src/main/java/io/druid/server/AsyncQueryForwardingServlet.java index f8f7d67576e4..c7f2b1167b3b 100644 --- a/server/src/main/java/io/druid/server/AsyncQueryForwardingServlet.java +++ b/server/src/main/java/io/druid/server/AsyncQueryForwardingServlet.java @@ -181,7 +181,10 @@ protected void service(HttpServletRequest request, HttpServletResponse response) request.setAttribute(HOST_ATTRIBUTE, defaultServer.getHost()); request.setAttribute(SCHEME_ATTRIBUTE, defaultServer.getScheme()); - final boolean isQueryEndpoint = request.getRequestURI().startsWith("/druid/v2"); + // The Router does not have the ability to look inside SQL queries and route them intelligently, so just treat + // them as a generic request. + final boolean isQueryEndpoint = request.getRequestURI().startsWith("/druid/v2") + && !request.getRequestURI().startsWith("/druid/v2/sql"); if (isQueryEndpoint && HttpMethod.DELETE.is(request.getMethod())) { // query cancellation request