diff --git a/src/test/org/apache/solr/handler/TestReplicationHandler.java b/src/test/org/apache/solr/handler/TestReplicationHandler.java
index 19f21fd694f..71d3f449dbe 100644
--- a/src/test/org/apache/solr/handler/TestReplicationHandler.java
+++ b/src/test/org/apache/solr/handler/TestReplicationHandler.java
@@ -397,14 +397,9 @@ public class TestReplicationHandler extends AbstractSolrTestCase {
   public void testReplicateAfterWrite2Slave() throws Exception {
 
     //add 500 docs to master
-    for (int i = 0; i < 500; i++)
+    for (int i = 0; i < 500; i++) {
       index(masterClient, "id", i, "name", "name = " + i);
-
-    masterClient.commit();
-
-    NamedList masterQueryRsp = query("*:*", masterClient);
-    SolrDocumentList masterQueryResult = (SolrDocumentList) masterQueryRsp.get("response");
-    assertEquals(500, masterQueryResult.getNumFound());
+    }
 
     String masterUrl = "http://localhost:" + masterJetty.getLocalPort() + "/solr/replication?command=disableReplication";
     URL url = new URL(masterUrl);
@@ -415,6 +410,12 @@ public class TestReplicationHandler extends AbstractSolrTestCase {
       //e.printStackTrace();
     }
 
+    masterClient.commit();
+
+    NamedList masterQueryRsp = query("*:*", masterClient);
+    SolrDocumentList masterQueryResult = (SolrDocumentList) masterQueryRsp.get("response");
+    assertEquals(500, masterQueryResult.getNumFound());
+
     index(slaveClient, "id", 555, "name", "name = " + 555);
     slaveClient.commit(true, true);