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 2018/08/27 19:41:02 UTC
svn commit: r1839370 -
/uima/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/OrchestratorComponent.java
Author: degenaro
Date: Mon Aug 27 19:41:02 2018
New Revision: 1839370
URL: http://svn.apache.org/viewvc?rev=1839370&view=rev
Log:
UIMA-5860 DUCC Orchestrator (OR) NullPointerException (NPE)
Modified:
uima/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/OrchestratorComponent.java
Modified: uima/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/OrchestratorComponent.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/OrchestratorComponent.java?rev=1839370&r1=1839369&r2=1839370&view=diff
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/OrchestratorComponent.java (original)
+++ uima/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/OrchestratorComponent.java Mon Aug 27 19:41:02 2018
@@ -657,6 +657,7 @@ implements Orchestrator {
IDuccProcess process = duccEvent.getProcess();
DuccId processDuccId = getProcessDuccId(duccEvent);
logger.debug(location, processDuccId, "process");
+ DuccId dwId = OrchestratorCommonArea.getInstance().getProcessAccounting().getJobId(processDuccId);
if(process == null) {
sb.append("process:"+process+" ");
sb.append("node:"+node+" ");
@@ -688,9 +689,16 @@ implements Orchestrator {
sb.append("processType:"+processType+" ");
logger.error(location, jobid, sb.toString());
}
+ else if(dwId == null) {
+ sb.append("id:"+id+" ");
+ sb.append("node:"+node+" ");
+ sb.append("lifefcycleEvent:"+lifecycleEvent.name()+" ");
+ sb.append("processType:"+processType+" ");
+ sb.append("dwId:"+dwId+" ");
+ logger.error(location, jobid, sb.toString());
+ }
else {
DuccWorkMap workMap = orchestratorCommonArea.getWorkMap();
- DuccId dwId = OrchestratorCommonArea.getInstance().getProcessAccounting().getJobId(processDuccId);
IDuccWork dw = workMap.findDuccWork(dwId);
DuccType dwType = dw.getDuccType();
sb.append("dwId:"+dwId+" ");