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());