commit 73880dfcd643c7eb20c0e60f616301acce74b7f6
author Sebastian Nagel <snagel@apache.org> Tue Apr 28 17:39:22 2020 +0200
committer GitHub <noreply@github.com> Tue Apr 28 17:39:22 2020 +0200
tree f882b0412dffd12bf3207e4bda656b812317565e
parent a455eb52ef560338d90a412bef9f6adfa45fc424
parent 81a4b92ac7576f7777b96a9197ff86d64c46ccda

Merge pull request #509 from sebastian-nagel/NUTCH-2778-indexer-elastic-log-errors

NUTCH-2778 indexer-elastic to properly log errors

src/plugin/indexer-elastic/src/java/org/apache/nutch/indexwriter/elastic/ElasticIndexWriter.java

diff --git a/src/plugin/indexer-elastic/src/java/org/apache/nutch/indexwriter/elastic/ElasticIndexWriter.java b/src/plugin/indexer-elastic/src/java/org/apache/nutch/indexwriter/elastic/ElasticIndexWriter.java
index a9aa354..d46dd6a 100644
--- a/src/plugin/indexer-elastic/src/java/org/apache/nutch/indexwriter/elastic/ElasticIndexWriter.java
+++ b/src/plugin/indexer-elastic/src/java/org/apache/nutch/indexwriter/elastic/ElasticIndexWriter.java
@@ -217,14 +217,15 @@
       @Override
       public void afterBulk(long executionId, BulkRequest request,
           Throwable failure) {
-        throw new RuntimeException(failure);
+        LOG.error("Elasticsearch indexing failed:", failure);
       }
 
       @Override
       public void afterBulk(long executionId, BulkRequest request,
           BulkResponse response) {
         if (response.hasFailures()) {
-          LOG.warn("Failures occurred during bulk request");
+          LOG.warn("Failures occurred during bulk request: {}",
+              response.buildFailureMessage());
         }
       }
     };