[nutch] branch master updated: NUTCH-2719: Showing a warning when an exchange points to an indexer that doesn't exist.

[r0ann3l]

This is an automated email from the ASF dual-hosted git repository.

r0ann3l pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nutch.git


The following commit(s) were added to refs/heads/master by this push:
     new 73b1286  NUTCH-2719: Showing a warning when an exchange points to an 
indexer that doesn't exist.
     new 5d2a76d  Merge pull request #465 from r0ann3l/NUTCH-2719
73b1286 is described below

commit 73b12863e95514863a338f6655b05e5f8ef6b971
Author: r0ann3l <roannel.f...@gmail.com>
AuthorDate: Tue Aug 27 10:51:03 2019 -0400

    NUTCH-2719: Showing a warning when an exchange points to an indexer that 
doesn't exist.
---
 src/java/org/apache/nutch/indexer/IndexWriters.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/src/java/org/apache/nutch/indexer/IndexWriters.java 
b/src/java/org/apache/nutch/indexer/IndexWriters.java
index 9fac2e2..7f5e9e3 100644
--- a/src/java/org/apache/nutch/indexer/IndexWriters.java
+++ b/src/java/org/apache/nutch/indexer/IndexWriters.java
@@ -16,7 +16,6 @@
  */
 package org.apache.nutch.indexer;
 
-import de.vandermeer.asciitable.AT_ColumnWidthCalculator;
 import de.vandermeer.asciitable.AT_Row;
 import de.vandermeer.asciitable.AsciiTable;
 import de.vandermeer.skb.interfaces.document.TableRowType;
@@ -218,6 +217,10 @@ public class IndexWriters {
 
   public void write(NutchDocument doc) throws IOException {
     for (String indexWriterId : getIndexWriters(doc)) {
+      if (!this.indexWriters.containsKey(indexWriterId)) {
+        LOG.warn("Index writer {} is not present. Maybe the plugin is not in 
plugin.includes or there is a misspelling.", indexWriterId);
+        continue;
+      }
       NutchDocument mappedDocument = mapDocument(doc,
           this.indexWriters.get(indexWriterId).getIndexWriterConfig()
               .getMapping());
@@ -228,6 +231,10 @@ public class IndexWriters {
 
   public void update(NutchDocument doc) throws IOException {
     for (String indexWriterId : getIndexWriters(doc)) {
+      if (!this.indexWriters.containsKey(indexWriterId)) {
+        LOG.warn("Index writer {} is not present. Maybe the plugin is not in 
plugin.includes or there is a misspelling.", indexWriterId);
+        continue;
+      }
       NutchDocument mappedDocument = mapDocument(doc,
           this.indexWriters.get(indexWriterId).getIndexWriterConfig()
               .getMapping());