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/12/19 15:53:20 UTC
svn commit: r1646756 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionEnd.java
Author: degenaro
Date: Fri Dec 19 14:53:20 2014
New Revision: 1646756
URL: http://svn.apache.org/r1646756
Log:
UIMA-4069 DUCC Job Driver (JD) system classpath
handle "error" work items
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionEnd.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionEnd.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionEnd.java?rev=1646756&r1=1646755&r2=1646756&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionEnd.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionEnd.java Fri Dec 19 14:53:20 2014
@@ -188,7 +188,6 @@ public class ActionEnd implements IActio
@Override
public void engage(Object objectData) {
String location = "engage";
- logger.debug(location, ILogger.null_id, "");
IActionData actionData = (IActionData) objectData;
try {
IWorkItem wi = actionData.getWorkItem();
@@ -208,9 +207,17 @@ public class ActionEnd implements IActio
int seqNo = metaCasHelper.getSystemKey();
Object exception = metaCas.getUserSpaceException();
if(exception != null) {
+ MessageBuffer mb = new MessageBuffer();
+ mb.append(Standardize.Label.seqNo.get()+wi.getMetaCas().getSystemKey());
+ mb.append("exception");
+ logger.info(location, ILogger.null_id, mb.toString());
handleException(actionData);
}
else {
+ MessageBuffer mb = new MessageBuffer();
+ mb.append(Standardize.Label.seqNo.get()+wi.getMetaCas().getSystemKey());
+ mb.append("ended");
+ logger.info(location, ILogger.null_id, mb.toString());
wisk.ended(seqNo);
successWorkItem(cm, wi, trans, metaCas, rwt);
pStats.done(wi);