Author: ferdy
Date: Fri Aug 31 12:56:41 2012
New Revision: 1379435
URL: http://svn.apache.org/viewvc?rev=1379435&view=rev
Log:
NUTCH-1463 Elasticsearch indexer should wait and check response for last flush
Modified:
nutch/branches/2.x/CHANGES.txt
nutch/branches/2.x/src/java/org/apache/nutch/indexer/elastic/ElasticWriter.java
Modified: nutch/branches/2.x/CHANGES.txt
URL:
http://svn.apache.org/viewvc/nutch/branches/2.x/CHANGES.txt?rev=1379435&r1=1379434&r2=1379435&view=diff
==============================================================================
--- nutch/branches/2.x/CHANGES.txt (original)
+++ nutch/branches/2.x/CHANGES.txt Fri Aug 31 12:56:41 2012
@@ -2,6 +2,8 @@ Nutch Change Log
Release 2.1 - Current Development
+* NUTCH-1463 Elasticsearch indexer should wait and check response for last
flush (ferdy)
+
* NUTCH-1462 Elasticsearch not indexing when type==null in NutchDocument
metadata (ferdy)
* NUTCH-1395 Show batchId when skipping within ParserJob (lewismc)
Modified:
nutch/branches/2.x/src/java/org/apache/nutch/indexer/elastic/ElasticWriter.java
URL:
http://svn.apache.org/viewvc/nutch/branches/2.x/src/java/org/apache/nutch/indexer/elastic/ElasticWriter.java?rev=1379435&r1=1379434&r2=1379435&view=diff
==============================================================================
---
nutch/branches/2.x/src/java/org/apache/nutch/indexer/elastic/ElasticWriter.java
(original)
+++
nutch/branches/2.x/src/java/org/apache/nutch/indexer/elastic/ElasticWriter.java
Fri Aug 31 12:56:41 2012
@@ -132,6 +132,7 @@ public class ElasticWriter implements Nu
// Flush pending requests
LOG.info("Processing remaining requests [docs = " + bulkDocs
+ ", length = " + bulkLength + ", total docs = " + indexedDocs + "]");
+ processExecute(false);
// flush one more time to finalize the last bulk
LOG.info("Processing to finalize last execute");
processExecute(false);
