CouchDB River: Deletes not handles correctly

mibesr · Oct 14, 2010 · 81fd17b · 81fd17b
1 parent eb44910
commit 81fd17b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugins/river/couchdb/src/main/java/org/elasticsearch/river/couchdb/CouchdbRiver.java b/plugins/river/couchdb/src/main/java/org/elasticsearch/river/couchdb/CouchdbRiver.java
@@ -186,7 +186,7 @@ private String processLine(String s, BulkRequestBuilder bulk) {
  return seq;
  }
 
- if (map.containsKey("delete") && map.get("deleted").equals("true")) {
+ if (map.containsKey("deleted") && map.get("deleted").equals(Boolean.TRUE)) {
  bulk.add(deleteRequest(indexName).type(typeName).id(id));
  } else if (map.containsKey("doc")) {
  Map<String, Object> doc = (Map<String, Object>) map.get("doc");