diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/index/engine/robin/RobinEngine.java b/modules/elasticsearch/src/main/java/org/elasticsearch/index/engine/robin/RobinEngine.java index 26c991a7aa7..ac3d683821b 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/index/engine/robin/RobinEngine.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/index/engine/robin/RobinEngine.java @@ -255,15 +255,15 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine, break; } } - if (bulk.refresh()) { - try { - refresh(new Refresh(false)); - } catch (Exception e) { - //ignore - } - } } dirty = true; + if (bulk.refresh()) { + try { + refresh(new Refresh(false)); + } catch (Exception e) { + //ignore + } + } } finally { rwl.readLock().unlock(); }