refresh param to bulk not working, closes elastic#614.

mute · Jan 28, 2011 · 116beae · 116beae
1 parent 96e4d8d
commit 116beae
Showing 1 changed file with 7 additions and 7 deletions.
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
@@ -232,15 +232,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();
         }