提交 f0e9d6fd 编写于 作者: F fjy

fix query forwarding

上级 98c3faa7
...@@ -68,13 +68,12 @@ public class RoutingDruidClient<IntermediateType, FinalType> ...@@ -68,13 +68,12 @@ public class RoutingDruidClient<IntermediateType, FinalType>
} }
public ListenableFuture<FinalType> run( public ListenableFuture<FinalType> run(
String host, String url,
Query query, Query query,
HttpResponseHandler<IntermediateType, FinalType> responseHandler HttpResponseHandler<IntermediateType, FinalType> responseHandler
) )
{ {
final ListenableFuture<FinalType> future; final ListenableFuture<FinalType> future;
final String url = String.format("http://%s/druid/v2/", host);
try { try {
log.debug("Querying url[%s]", url); log.debug("Querying url[%s]", url);
......
...@@ -210,7 +210,7 @@ public class AsyncQueryForwardingServlet extends HttpServlet ...@@ -210,7 +210,7 @@ public class AsyncQueryForwardingServlet extends HttpServlet
@Override @Override
public void run() public void run()
{ {
routingDruidClient.run(host, theQuery, responseHandler); routingDruidClient.run(makeUrl(host, req), theQuery, responseHandler);
} }
} }
); );
...@@ -236,4 +236,9 @@ public class AsyncQueryForwardingServlet extends HttpServlet ...@@ -236,4 +236,9 @@ public class AsyncQueryForwardingServlet extends HttpServlet
.emit(); .emit();
} }
} }
private String makeUrl(String host, HttpServletRequest req)
{
return String.format("http://%s%s?%s", host, req.getRequestURI(), req.getQueryString());
}
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册