refresh param to bulk not working, closes #614.

2011-01-09 22:06:51 +02:00 · 2011-01-09 22:06:51 +02:00 · d650705a03
parent 373af6b1e0
commit d650705a03
1 changed files with 7 additions and 7 deletions
--- 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,6 +255,8 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine,
                            break;
                    }
                }
+            }
+            dirty = true;
            if (bulk.refresh()) {
                try {
                    refresh(new Refresh(false));
@ -262,8 +264,6 @@ public class RobinEngine extends AbstractIndexShardComponent implements Engine,
                    //ignore
                }
            }
-            }
-            dirty = true;
        } finally {
            rwl.readLock().unlock();
        }