You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@nutch.apache.org by fe...@apache.org on 2012/08/31 14:56:42 UTC

svn commit: r1379435 - in /nutch/branches/2.x: CHANGES.txt src/java/org/apache/nutch/indexer/elastic/ElasticWriter.java

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