diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/common/lucene/search/FilteredCollector.java b/modules/elasticsearch/src/main/java/org/elasticsearch/common/lucene/search/FilteredCollector.java
index 1453db1cf88..2981a937151 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/common/lucene/search/FilteredCollector.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/common/lucene/search/FilteredCollector.java
@@ -55,6 +55,7 @@ public class FilteredCollector extends Collector {
     }
 
     @Override public void setNextReader(IndexReader reader, int docBase) throws IOException {
+        collector.setNextReader(reader, docBase);
         docSet = DocSets.convert(reader, filter.getDocIdSet(reader));
     }