Repository: oozie Updated Branches: refs/heads/master 04dae7c6c -> cc02d91d9
OOZIE-2079 Notify when a coordinator action status becomes RUNNING. (Mohammad) Project: http://git-wip-us.apache.org/repos/asf/oozie/repo Commit: http://git-wip-us.apache.org/repos/asf/oozie/commit/cc02d91d Tree: http://git-wip-us.apache.org/repos/asf/oozie/tree/cc02d91d Diff: http://git-wip-us.apache.org/repos/asf/oozie/diff/cc02d91d Branch: refs/heads/master Commit: cc02d91d9e6db3b79f5dd2b92dd461f25662bdcc Parents: 04dae7c Author: Mohammad Islam <[email protected]> Authored: Mon Jan 5 15:39:11 2015 -0800 Committer: Mohammad Islam <[email protected]> Committed: Mon Jan 5 15:39:11 2015 -0800 ---------------------------------------------------------------------- .../org/apache/oozie/command/coord/CoordActionStartXCommand.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oozie/blob/cc02d91d/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java b/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java index 1dd8272..2223b13 100644 --- a/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/coord/CoordActionStartXCommand.java @@ -210,6 +210,7 @@ public class CoordActionStartXCommand extends CoordinatorXCommand<Void> { CoordActionQuery.UPDATE_COORD_ACTION_FOR_START, coordAction)); try { executor.executeBatchInsertUpdateDelete(insertList, updateList, null); + queue(new CoordActionNotificationXCommand(coordAction), 100); if (EventHandlerService.isEnabled()) { generateEvent(coordAction, user, appName, wfJob.getStartTime()); }
