Author: degenaro Date: Wed Jun 26 13:07:29 2013 New Revision: 1496920 URL: http://svn.apache.org/r1496920 Log: UIMA-2987 DUCC job driver (JD) should reap unprocessed work items
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/JobManagerConverter.java Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/JobManagerConverter.java URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/JobManagerConverter.java?rev=1496920&r1=1496919&r2=1496920&view=diff ============================================================================== --- uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/JobManagerConverter.java (original) +++ uima/sandbox/uima-ducc/trunk/uima-ducc-rm/src/main/java/org/apache/uima/ducc/rm/JobManagerConverter.java Wed Jun 26 13:07:29 2013 @@ -152,7 +152,7 @@ public class JobManagerConverter return; } else { int total_work = toInt(si.getWorkItemsTotal(), scheduler.getDefaultNTasks()); - int completed_work = toInt(si.getWorkItemsCompleted(), 0) + toInt(si.getWorkItemsError(), 0); + int completed_work = toInt(si.getWorkItemsCompleted(), 0) + toInt(si.getWorkItemsError(), 0)+ toInt(si.getWorkItemsLost(), 0); int max_shares = toInt(si.getSharesMax(), Integer.MAX_VALUE); int existing_max_shares = j.getMaxShares();