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/06/11 16:56:47 UTC
svn commit: r1684912 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/configuration/jd/JobDriverStateExchanger.java
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) {