diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java index 48297d139f6..f722549d6ff 100644 --- a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java +++ b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java @@ -329,13 +329,6 @@ public class RealtimePlumber implements Plumber @Override public QueryRunner 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(descriptor); - } - if (skipIncrementalSegment && !input.hasSwapped()) { return new NoopQueryRunner(); }