diff --git a/modules/test/integration/src/test/java/org/elasticsearch/test/stress/rollingrestart/RollingRestartStressTest.java b/modules/test/integration/src/test/java/org/elasticsearch/test/stress/rollingrestart/RollingRestartStressTest.java
index 42755e2207b..459cc1784bb 100644
--- a/modules/test/integration/src/test/java/org/elasticsearch/test/stress/rollingrestart/RollingRestartStressTest.java
+++ b/modules/test/integration/src/test/java/org/elasticsearch/test/stress/rollingrestart/RollingRestartStressTest.java
@@ -67,6 +67,7 @@ public class RollingRestartStressTest {
     private Node client;
 
     private AtomicLong indexCounter = new AtomicLong();
+    private AtomicLong idCounter = new AtomicLong();
 
 
     public RollingRestartStressTest numberOfNodes(int numberOfNodes) {
@@ -253,7 +254,8 @@ public class RollingRestartStressTest {
 
         json.endObject();
 
-        client.client().prepareIndex("test", "type1")
+        client.client().prepareIndex("test", "type1", Long.toString(idCounter.incrementAndGet()))
+                .setCreate(true)
                 .setSource(json)
                 .execute().actionGet();
         indexCounter.incrementAndGet();