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

remove wrong checks 

sink never have null hydrants and hydrants never have null adapters
This commit is contained in:
Nishant 2016-01-20 23:43:53 +05:30
parent 59ea186af7
commit 61aca6f9cc
1 changed files with 0 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java
View File

@ -329,13 +329,6 @@ public class RealtimePlumber implements Plumber
@Override @Override
public QueryRunner<T> apply(FireHydrant input) public QueryRunner<T> apply(FireHydrant input)
{ {
// It is possible that we got a query for a segment, and while that query
// is in the jetty queue, the segment is abandoned. Here, we need to retry
// the query for the segment.
if (input == null || input.getSegment() == null) {
return new ReportTimelineMissingSegmentQueryRunner<T>(descriptor);
}
if (skipIncrementalSegment && !input.hasSwapped()) { if (skipIncrementalSegment && !input.hasSwapped()) {
return new NoopQueryRunner<T>(); return new NoopQueryRunner<T>();
} }