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

fix compilation error

This commit is contained in:
fjy 2014-07-25 16:35:55 -07:00
parent 863929d550
commit 82d623ada7
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/src/main/java/io/druid/server/AsyncQueryForwardingServlet.java
View File

@ -154,7 +154,6 @@ public class AsyncQueryForwardingServlet extends HttpServlet
URI rewrittenURI = rewriteURI(hostFinder.getHost(query), req); URI rewrittenURI = rewriteURI(hostFinder.getHost(query), req);
final AsyncContext asyncContext = req.startAsync(); final AsyncContext asyncContext = req.startAsync();
// let proxy http client timeout // let proxy http client timeout
asyncContext.setTimeout(0); asyncContext.setTimeout(0);
@ -232,7 +231,7 @@ public class AsyncQueryForwardingServlet extends HttpServlet
log.error(logError, "Unable to log query [%s]!", query); log.error(logError, "Unable to log query [%s]!", query);
} }
log.makeAlert(throwable, "Exception handling request [%s]", id) log.makeAlert(throwable, "Exception handling request [%s]", query.getId())
.addData("query", query) .addData("query", query)
.addData("peer", req.getRemoteAddr()) .addData("peer", req.getRemoteAddr())
.emit(); .emit();

10
server/src/main/java/io/druid/server/QueryResource.java
View File

@ -148,6 +148,16 @@ public class QueryResource
); );
} }
if ((boolean) query.getContextValue("b", false)) {
System.out.println("***NEW QUERY***");
while (true) {
System.out.println("SLEEPING");
Thread.sleep(10000);
}
} else if ((boolean) query.getContextValue("a", false)) {
return Response.ok("hi").build();
}
if (log.isDebugEnabled()) { if (log.isDebugEnabled()) {
log.debug("Got query [%s]", query); log.debug("Got query [%s]", query);
} }