svn commit: r1737718 - /uima/sandbox/uima-ducc/trunk/uima-ducc-orchestrator/src/main/java/org/apache/uima/ducc/orchestrator/ProcessAccounting.java

[degenaro]

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;
        }