fix wrong check on close

2012-08-23 20:58:40 +02:00 · 2012-08-23 20:58:40 +02:00 · ba98b04081
parent bb609f696f
commit ba98b04081
1 changed files with 0 additions and 1 deletions
--- a/src/main/java/org/elasticsearch/action/bulk/BulkProcessor.java
+++ b/src/main/java/org/elasticsearch/action/bulk/BulkProcessor.java
@ -243,7 +243,6 @@ public class BulkProcessor {
        if (closed) {
            throw new ElasticSearchIllegalStateException("bulk process already closed");
        }
-        this.closed = true;
        if (!isOverTheLimit()) {
            return;
        }