Author: degenaro Date: Mon Apr 4 18:25:41 2016 New Revision: 1737718 URL: http://svn.apache.org/viewvc?rev=1737718&view=rev Log: UIMA-4882 DUCC Resource Manager (RM) does not adequately expand Job Processes (JPs)
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java?rev=1737718&r1=1737717&r2=1737718&view=diff ============================================================================== --- uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java (original) +++ uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java Mon Apr 4 18:25:41 2016 @@ -36,6 +36,7 @@ import org.apache.uima.ducc.transport.ev import org.apache.uima.ducc.transport.event.common.DuccWorkMap; import org.apache.uima.ducc.transport.event.common.IDuccProcess; import org.apache.uima.ducc.transport.event.common.IDuccProcessMap; +import org.apache.uima.ducc.transport.event.common.IDuccSchedulingInfo; import org.apache.uima.ducc.transport.event.common.IDuccState.JobState; import org.apache.uima.ducc.transport.event.common.IDuccWork; import org.apache.uima.ducc.transport.event.common.IDuccWorkExecutable; @@ -796,9 +797,14 @@ public class ProcessAccounting { duccWorkJob.getSchedulingInfo().setWorkItemsPreempt(jdPreemptWorkItems); } - duccWorkJob.getSchedulingInfo().setMostRecentWorkItemStart(jdStatusReport.getMostRecentStart()); - duccWorkJob.getSchedulingInfo().setPerWorkItemStatistics(jdStatusReport.getPerWorkItemStatistics()); + IDuccSchedulingInfo si = duccWorkJob.getSchedulingInfo(); + + si.setMostRecentWorkItemStart(jdStatusReport.getMostRecentStart()); + si.setPerWorkItemStatistics(jdStatusReport.getPerWorkItemStatistics()); + double avgTimeForWorkItemsSkewedByActive = jdStatusReport.getAvgTimeForWorkItemsSkewedByActive(); + si.setAvgTimeForWorkItemsSkewedByActive(avgTimeForWorkItemsSkewedByActive); + logger.trace(methodName, null, messages.fetch("exit")); return retVal; }