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 index a8a663d960ce4..912f19f5ab5cc 100644 --- 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 @@ -179,6 +179,13 @@ private String processLine(String s, BulkRequestBuilder bulk) { } String seq = map.get("seq").toString(); String id = map.get("id").toString(); + + // Ignore design documents + if (id.startsWith("_design/")) { + logger.info("ignoring design document {}", id); + return seq; + } + if (map.containsKey("delete") && map.get("deleted").equals("true")) { bulk.add(deleteRequest(indexName).type(typeName).id(id)); } else if (map.containsKey("doc")) {