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

Add flush prior to close on output stream in QueryResource

This commit is contained in:
Charles Allen 2015-06-16 11:40:56 -07:00
parent 6763e3780a
commit 69bbe21512
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -183,6 +183,7 @@ public class QueryResource
{ {
// json serializer will always close the yielder // json serializer will always close the yielder
jsonWriter.writeValue(outputStream, yielder); jsonWriter.writeValue(outputStream, yielder);
outputStream.flush(); // Some types of OutputStream suppress flush errors in the .close() method.
outputStream.close(); outputStream.close();
final long queryTime = System.currentTimeMillis() - start; final long queryTime = System.currentTimeMillis() - start;
@ -213,7 +214,7 @@ public class QueryResource
.build(); .build();
} }
catch (Exception e) { catch (Exception e) {
// make sure to close yieder if anything happened before starting to serialize the response. // make sure to close yielder if anything happened before starting to serialize the response.
yielder.close(); yielder.close();
throw Throwables.propagate(e); throw Throwables.propagate(e);
} }