Browse files

throwin exception on any indexing error

  • Loading branch information...
1 parent 6b6d9a7 commit 6160791eef0e3b2334d656b4116ab0ba00e721eb @mschoch mschoch committed Mar 31, 2014
View
1 src/main/java/org/elasticsearch/transport/couchbase/capi/ElasticSearchCAPIBehavior.java
@@ -318,6 +318,7 @@ public boolean ensureFullCommit(String database) {
itemResponse.put("error", "failed");
itemResponse.put("reason", bulkItemResponse.getFailureMessage());
logger.error("indexing error for id: {} reason: {}", itemId, bulkItemResponse.getFailureMessage());
+ throw new RuntimeException("indexing error " + bulkItemResponse.getFailureMessage());
} else {
itemResponse.put("rev", revisions.get(itemId));
}

0 comments on commit 6160791

Please sign in to comment.