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 3ec7cf25841..71e552377c0 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 @@ -259,7 +259,7 @@ public class CouchdbRiver extends AbstractRiverComponent implements River { } } - String file = "/" + couchDb + "/_changes?feed=continuous&include_docs=true&&heartbeat=10000"; + String file = "/" + couchDb + "/_changes?feed=continuous&include_docs=true&heartbeat=10000"; if (couchFilter != null) { file = file + "&filter=" + couchFilter; }