You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2013/11/01 10:34:31 UTC
svn commit: r1537866 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java
Author: degenaro
Date: Fri Nov 1 09:34:31 2013
New Revision: 1537866
URL: http://svn.apache.org/r1537866
Log:
UIMA-3337 DUCC orchestrator (OR) Failed Initialization for Service incorrectly marked Completed with EOJ??
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java?rev=1537866&r1=1537865&r2=1537866&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java Fri Nov 1 09:34:31 2013
@@ -332,6 +332,7 @@ public class StateManager {
IDuccProcess process = processMap.get(processId);
IDuccProcessWorkItems pwi = pwiMap.get(processId);
process.setProcessWorkItems(pwi);
+ logger.trace(methodName, job.getDuccId(), "done:"+pwi.getCountDone()+" "+"error:"+pwi.getCountError()+" "+"dispatch:"+pwi.getCountDispatch()+" "+"unassigned:"+pwi.getCountUnassigned()+" "+"lost:"+pwi.getCountLost());
}
}
catch(Throwable t) {
@@ -345,7 +346,6 @@ public class StateManager {
DuccProcessWorkItemsMap pwiMap = jdStatusReport.getDuccProcessWorkItemsMap();
IDuccProcessWorkItems pwi = pwiMap.getTotals();
pwi.setCountUnassigned(jdStatusReport.getWorkItemPendingProcessAssignmentCount());
- logger.debug(methodName, job.getDuccId(), "done:"+pwi.getCountDone()+" "+"error:"+pwi.getCountError()+" "+"dispatch:"+pwi.getCountDispatch()+" "+"unassigned:"+pwi.getCountUnassigned()+" "+"lost:"+pwi.getCountLost());
DuccWorkPopDriver driver = job.getDriver();
IDuccProcessMap processMap = driver.getProcessMap();
if(processMap != null) {
@@ -354,6 +354,7 @@ public class StateManager {
DuccId processId = iterator.next();
IDuccProcess process = processMap.get(processId);
process.setProcessWorkItems(pwi);
+ logger.debug(methodName, job.getDuccId(), "done:"+pwi.getCountDone()+" "+"error:"+pwi.getCountError()+" "+"dispatch:"+pwi.getCountDispatch()+" "+"unassigned:"+pwi.getCountUnassigned()+" "+"lost:"+pwi.getCountLost());
}
}
}
@@ -1230,9 +1231,11 @@ public class StateManager {
else if(lost > 0) {
setCompletionIfNotAlreadySet(job, JobCompletionType.Lost, new Rationale("state manager detected lost work items="+lost));
}
+ // <UIMA-3337>
else {
setCompletionIfNotAlreadySet(job, JobCompletionType.EndOfJob, rationale);
}
+ // </UIMA-3337>
completeJob(job, rationale);
}
break;