refresh param to bulk not working, closes #614.

elastic · Jan 9, 2011 · d650705 · d650705
1 parent 373af6b
commit d650705
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
@@ -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();
         }