diff --git a/realtime/src/main/java/com/metamx/druid/realtime/MinTimeFirehose.java b/realtime/src/main/java/com/metamx/druid/realtime/MinTimeFirehose.java
index 86d01e4f3c2..5660cf0bc0b 100644
--- a/realtime/src/main/java/com/metamx/druid/realtime/MinTimeFirehose.java
+++ b/realtime/src/main/java/com/metamx/druid/realtime/MinTimeFirehose.java
@@ -44,20 +44,9 @@ public class MinTimeFirehose implements Firehose
   @Override
   public InputRow nextRow()
   {
-    if (savedInputRow != null) {
-      final InputRow row = savedInputRow;
-      savedInputRow = null;
-      return row;
-    } else {
-      while (firehose.hasMore()) {
-        final InputRow row = firehose.nextRow();
-        if (acceptable(row)) {
-          return row;
-        }
-      }
-
-      throw new NoSuchElementException("No more rows!");
-    }
+    final InputRow row = savedInputRow;
+    savedInputRow = null;
+    return row;
   }
 
   @Override