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/12/06 20:06:35 UTC
svn commit: r1548667 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/StateManager.java
Author: degenaro
Date: Fri Dec 6 19:06:34 2013
New Revision: 1548667
URL: http://svn.apache.org/r1548667
Log:
UIMA-3489 DUCC failed service instance Reason should not be 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=1548667&r1=1548666&r2=1548667&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 Dec 6 19:06:34 2013
@@ -1373,14 +1373,19 @@ public class StateManager {
}
private void completeService(DuccWorkJob service, IRationale rationale) {
+ String location = "completeService";
+ DuccId jobid = service.getDuccId();
if(service.getProcessFailureCount() > 0) {
service.setCompletion(JobCompletionType.Warning, new Rationale("process failure(s) occurred"));
+ logger.debug(location, jobid, service.getCompletionRationale().getText()+", "+"ProcessFailureCount="+service.getProcessFailureCount());
}
else if(service.getProcessInitFailureCount() > 0) {
service.setCompletion(JobCompletionType.Warning, new Rationale("process initialization failure(s) occurred"));
+ logger.debug(location, jobid, service.getCompletionRationale().getText()+", "+"ProcessInitFailureCount="+service.getProcessInitFailureCount());
}
else {
setCompletionIfNotAlreadySet(service, JobCompletionType.EndOfJob, rationale);
+ logger.debug(location, jobid, service.getCompletionRationale().getText()+", "+"no failures");
}
advanceToCompleted(service);
}