Author: mona
Date: Sat Jun 29 18:35:06 2013
New Revision: 1497997

URL: http://svn.apache.org/r1497997
Log:
Sync CoordKillXCommand with trunk code

Modified:
    
oozie/branches/branch-4.0/core/src/main/java/org/apache/oozie/command/coord/CoordKillXCommand.java

Modified: 
oozie/branches/branch-4.0/core/src/main/java/org/apache/oozie/command/coord/CoordKillXCommand.java
URL: 
http://svn.apache.org/viewvc/oozie/branches/branch-4.0/core/src/main/java/org/apache/oozie/command/coord/CoordKillXCommand.java?rev=1497997&r1=1497996&r2=1497997&view=diff
==============================================================================
--- 
oozie/branches/branch-4.0/core/src/main/java/org/apache/oozie/command/coord/CoordKillXCommand.java
 (original)
+++ 
oozie/branches/branch-4.0/core/src/main/java/org/apache/oozie/command/coord/CoordKillXCommand.java
 Sat Jun 29 18:35:06 2013
@@ -34,6 +34,7 @@ import org.apache.oozie.executor.jpa.Bul
 import org.apache.oozie.executor.jpa.CoordJobGetActionsNotCompletedJPAExecutor;
 import org.apache.oozie.executor.jpa.CoordJobGetJPAExecutor;
 import org.apache.oozie.executor.jpa.JPAExecutorException;
+import org.apache.oozie.service.EventHandlerService;
 import org.apache.oozie.service.JPAService;
 import org.apache.oozie.service.Services;
 import org.apache.oozie.util.LogUtils;
@@ -113,7 +114,8 @@ public class CoordKillXCommand extends K
             // set pending to false
             action.setPending(0);
         }
-        if (prevStatus != CoordinatorAction.Status.RUNNING && prevStatus != 
CoordinatorAction.Status.SUSPENDED) {
+        if (EventHandlerService.isEnabled() && prevStatus != 
CoordinatorAction.Status.RUNNING
+                && prevStatus != CoordinatorAction.Status.SUSPENDED) {
             CoordinatorXCommand.generateEvent(action, coordJob.getUser(), 
coordJob.getAppName(), null);
         }
         action.setLastModifiedTime(new Date());


Reply via email to