From 61aca6f9cc8c5a9828128d6947d5df163bf89a27 Mon Sep 17 00:00:00 2001 From: Nishant Date: Wed, 20 Jan 2016 23:43:53 +0530 Subject: [PATCH] remove wrong checks sink never have null hydrants and hydrants never have null adapters --- .../io/druid/segment/realtime/plumber/RealtimePlumber.java | 7 ------- 1 file changed, 7 deletions(-) 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(); }