Author: degenaro
Date: Thu Jun 11 14:56:47 2015
New Revision: 1684912
URL: http://svn.apache.org/r1684912
Log:
UIMA-4458 DUCC Job Driver (JD) is too verbose when config'd at debug level
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverStateExchanger.java
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverStateExchanger.java
URL:
http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverStateExchanger.java?rev=1684912&r1=1684911&r2=1684912&view=diff
==============================================================================
---
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverStateExchanger.java
(original)
+++
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverStateExchanger.java
Thu Jun 11 14:56:47 2015
@@ -28,7 +28,9 @@ import org.apache.uima.ducc.common.utils
import org.apache.uima.ducc.common.utils.DuccPropertiesResolver;
import org.apache.uima.ducc.common.utils.id.DuccId;
import org.apache.uima.ducc.container.jd.JobDriver;
+import org.apache.uima.ducc.container.jd.blacklist.JobProcessBlacklist;
import org.apache.uima.ducc.container.jd.mh.IMessageHandler;
+import org.apache.uima.ducc.container.jd.mh.RemoteWorkerProcess;
import org.apache.uima.ducc.container.jd.mh.iface.IOperatingInfo;
import org.apache.uima.ducc.container.jd.mh.iface.IProcessInfo;
import org.apache.uima.ducc.container.jd.mh.impl.ProcessInfo;
@@ -47,6 +49,8 @@ import org.apache.uima.ducc.transport.ev
public class JobDriverStateExchanger extends Thread {
+ private JobProcessBlacklist jobProcessBlacklist =
JobProcessBlacklist.getInstance();
+
private static final DuccLogger logger =
DuccLoggerComponents.getOrLogger(JobDriverStateExchanger.class.getName());
private static final DuccId jobid = null;
@@ -209,9 +213,20 @@ public class JobDriverStateExchanger ext
String reasonDeallocated = null;
ProcessDeallocationType
processDeallocationType = p.getProcessDeallocationType();
if(processDeallocationType != null) {
- reasonDeallocated =
processDeallocationType.name();
-
sb.append("reason[deallocated]:"+reasonDeallocated);
- sb.append(" ");
+ switch(processDeallocationType)
{
+ case Undefined:
+ break;
+ default:
+ reasonDeallocated =
processDeallocationType.name();
+
sb.append("reason[deallocated]:"+reasonDeallocated);
+ sb.append(" ");
+ break;
+ }
+ }
+ RemoteWorkerProcess rwp =
RemoteWorkerProcess.factory(node, ip, pidName, pid);
+ if(jobProcessBlacklist.includes(rwp)) {
+ logger.trace(location, jobid,
sb.toString());
+ continue;
}
logger.debug(location, jobid,
sb.toString());
switch(state) {
