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

fix router bug

This commit is contained in:
fjy 2014-07-29 21:44:07 -07:00
parent 0c898c58d1
commit 3920300900
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -49,6 +49,7 @@ import javax.servlet.http.HttpServletResponse;
import java.io.IOException; import java.io.IOException;
import java.net.URI; import java.net.URI;
import java.util.Enumeration; import java.util.Enumeration;
import java.util.UUID;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
/** /**
@ -116,6 +117,9 @@ public class AsyncQueryForwardingServlet extends AsyncProxyServlet
inputQuery = objectMapper.readValue(request.getInputStream(), Query.class); inputQuery = objectMapper.readValue(request.getInputStream(), Query.class);
if (inputQuery != null) { if (inputQuery != null) {
host = hostFinder.getHost(inputQuery); host = hostFinder.getHost(inputQuery);
if (inputQuery.getId() == null) {
inputQuery = inputQuery.withId(UUID.randomUUID().toString());
}
} }
} }
catch (IOException e) { catch (IOException e) {