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 2015/03/27 12:34:36 UTC
svn commit: r1669541 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/JobDriver.java
Author: degenaro
Date: Fri Mar 27 11:34:35 2015
New Revision: 1669541
URL: http://svn.apache.org/r1669541
Log:
UIMA-4311 DUCC Job Driver (JD) clean-up Junit tests
- fix NumberFormatException in Junit tests (and ultimately in job submissions employing default work item timeout)
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/JobDriver.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/JobDriver.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/JobDriver.java?rev=1669541&r1=1669540&r2=1669541&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/JobDriver.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/JobDriver.java Fri Mar 27 11:34:35 2015
@@ -119,10 +119,18 @@ public class JobDriver {
try {
FlagsExtendedHelper feh = FlagsExtendedHelper.getInstance();
String workItemTimeout = feh.getWorkItemTimeout();
- workItemTimeoutMillis = Long.parseLong(workItemTimeout)*(60*1000);
- MessageBuffer mb = new MessageBuffer();
- mb.append(Standardize.Label.value.get()+workItemTimeoutMillis);
- logger.trace(location, ILogger.null_id, mb.toString());
+ String value = workItemTimeout;
+ if(value != null) {
+ workItemTimeoutMillis = Long.parseLong(workItemTimeout)*(60*1000);
+ MessageBuffer mb = new MessageBuffer();
+ mb.append(Standardize.Label.value.get()+workItemTimeoutMillis);
+ logger.trace(location, ILogger.null_id, mb.toString());
+ }
+ else {
+ MessageBuffer mb = new MessageBuffer();
+ mb.append(Standardize.Label.value.get()+workItemTimeoutMillis);
+ logger.trace(location, ILogger.null_id, mb.toString());
+ }
}
catch(Exception e) {
logger.error(location, ILogger.null_id, e);