This is an automated email from the ASF dual-hosted git repository. snagel pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/nutch.git
commit 9fcc2a494acfb2b367078dcec84f264e57413315 Author: Nicola Marcacci Rossi <[email protected]> AuthorDate: Fri Dec 15 12:05:44 2017 +0100 fix delete --- .../apache/nutch/indexwriter/elasticrest/ElasticRestIndexWriter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/plugin/indexer-elastic-rest/src/java/org/apache/nutch/indexwriter/elasticrest/ElasticRestIndexWriter.java b/src/plugin/indexer-elastic-rest/src/java/org/apache/nutch/indexwriter/elasticrest/ElasticRestIndexWriter.java index 34ab661..56cfab1 100644 --- a/src/plugin/indexer-elastic-rest/src/java/org/apache/nutch/indexwriter/elasticrest/ElasticRestIndexWriter.java +++ b/src/plugin/indexer-elastic-rest/src/java/org/apache/nutch/indexwriter/elasticrest/ElasticRestIndexWriter.java @@ -237,9 +237,9 @@ public class ElasticRestIndexWriter implements IndexWriter { if (languages != null && languages.length > 0) { Bulk.Builder bulkBuilder = new Bulk.Builder().defaultType(defaultType); for (String lang : languages) { - bulkBuilder.addAction(new Delete.Builder(key).index(defaultIndex + "_" + lang).build()); + bulkBuilder.addAction(new Delete.Builder(key).index(defaultIndex + "_" + lang).type(defaultType).build()); } - bulkBuilder.addAction(new Delete.Builder(key).index(defaultIndex + "_others").build()); + bulkBuilder.addAction(new Delete.Builder(key).index(defaultIndex + "_others").type(defaultType).build()); client.execute(bulkBuilder.build()); } else { client.execute(new Delete.Builder(key).index(defaultIndex) -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
