diff --git a/external/elasticsearch/src/main/java/com/digitalpebble/stormcrawler/elasticsearch/persistence/HybridSpout.java b/external/elasticsearch/src/main/java/com/digitalpebble/stormcrawler/elasticsearch/persistence/HybridSpout.java
index <HASH>..<HASH> 100644
--- a/external/elasticsearch/src/main/java/com/digitalpebble/stormcrawler/elasticsearch/persistence/HybridSpout.java
+++ b/external/elasticsearch/src/main/java/com/digitalpebble/stormcrawler/elasticsearch/persistence/HybridSpout.java
@@ -84,6 +84,13 @@ public class HybridSpout extends AggregationSpout
             // not interested in this one any more
             return;
         }
+        
+        // reloading the aggregs - searching now 
+        // would just overload ES and yield
+        // mainly duplicates
+        if (isInQuery.get()) {
+            return;
+        }
 
         LOG.info("Querying for more docs for {}", queueName);
HybridSpout - do not emit a term query if an aggregation has been emitted