diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java b/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java
index 776cb7d7f1e..fd599c68d51 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/service/InternalIndexShard.java
@@ -622,7 +622,7 @@ public class InternalIndexShard extends AbstractIndexShardComponent implements I
                 @Override public void run() {
                     try {
                         if (engine.refreshNeeded()) {
-                            engine.refresh(new Engine.Refresh(false));
+                            refresh(new Engine.Refresh(false));
                         }
                     } catch (EngineClosedException e) {
                         // we are being closed, ignore