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 2014/07/02 16:41:55 UTC
svn commit: r1607380 - in
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd:
DriverStatusReport.java IDriverState.java
Author: degenaro
Date: Wed Jul 2 14:41:54 2014
New Revision: 1607380
URL: http://svn.apache.org/r1607380
Log:
UIMA-3921 When a JD fails to start (e.g. classpath error) it marks the job as complete
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverState.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java?rev=1607380&r1=1607379&r2=1607380&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java Wed Jul 2 14:41:54 2014
@@ -259,6 +259,13 @@ public class DriverStatusReport implemen
logReport();
}
+ public void setFailed(IRationale rationale) {
+ setClientInitEnd(System.currentTimeMillis());
+ setDriverState(DriverState.Failed);
+ setJobCompletion(JobCompletionType.CanceledByDriver, rationale);
+ logReport();
+ }
+
public void setInitializingFailed(IRationale rationale) {
setClientInitEnd(System.currentTimeMillis());
setDriverState(DriverState.Completed);
@@ -643,6 +650,8 @@ public class DriverStatusReport implemen
private void calculateState() {
String methodName = "calculateState";
switch(getDriverState()) {
+ case Failed:
+ break;
case Initializing:
if(getAtLeastOneService()) {
setDriverState(DriverState.Running);
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverState.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverState.java?rev=1607380&r1=1607379&r2=1607380&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverState.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverState.java Wed Jul 2 14:41:54 2014
@@ -27,6 +27,7 @@ public interface IDriverState {
Running, // CAS processing active
Completing, // Driver processing is completing
Completed, // Driver processing is completed
+ Failed, // Driver failed
Undefined // None of the above
};