diff --git a/src/java/org/apache/solr/handler/ReplicationHandler.java b/src/java/org/apache/solr/handler/ReplicationHandler.java index 2a045ca264b..903be6d3142 100644 --- a/src/java/org/apache/solr/handler/ReplicationHandler.java +++ b/src/java/org/apache/solr/handler/ReplicationHandler.java @@ -789,6 +789,7 @@ public class ReplicationHandler extends RequestHandlerBase implements SolrCoreAw if(indexVersion != null && (packetsWritten % 5 == 0)){ delPolicy.setReserveDuration(indexVersion, reserveCommitDuration); } + packetsWritten++; } } else { writeNothing();