[gate-cvs] SF.net SVN: gate:[20272] gcp/trunk/src/gate/cloud/batch/ PooledDocumentProcessor.java

[<ian...@us...>]

Revision: 20272
          http://sourceforge.net/p/gate/code/20272
Author:   ian_roberts
Date:     2017-10-31 18:56:39 +0000 (Tue, 31 Oct 2017)
Log Message:
-----------
If an exception occurs here, it means there was a problem getting documents from the streaming handler.  If this is the first document then dd will be null, if it's not the first document then dd will be the last one that was processed successfully, and in neither case does it make sense to reportFailure.

Modified Paths:
--------------
    gcp/trunk/src/gate/cloud/batch/PooledDocumentProcessor.java

Modified: gcp/trunk/src/gate/cloud/batch/PooledDocumentProcessor.java
===================================================================
--- gcp/trunk/src/gate/cloud/batch/PooledDocumentProcessor.java	2017-10-27 10:19:03 UTC (rev 20271)
+++ gcp/trunk/src/gate/cloud/batch/PooledDocumentProcessor.java	2017-10-31 18:56:39 UTC (rev 20272)
@@ -286,8 +286,7 @@
     catch(InterruptedException e) {
       Thread.currentThread().interrupt();
     } catch(Exception e) {
-      log.error("Error processing document " + dd.id, e);
-      reportFailure(dd.id, dd, e);
+      log.error("Error getting documents from streaming input handler", e);
     }
   }
 

This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.