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 6c8753f2df1..3ec7cf25841 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 @@ -251,6 +251,7 @@ public class CouchdbRiver extends AbstractRiverComponent implements River { logger.warn("failed to get last_seq, throttling....", e); try { Thread.sleep(5000); + continue; } catch (InterruptedException e1) { if (closed) { return;