Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Closes OOZIE-113 merge changes for OOZIE-101 to ActionEndXCommand

  • Loading branch information...
commit c52c3652011f44f6b9b6ab33819be6167805e93f 1 parent 1637058
Angelo Kaichen Huang authored
View
9 core/src/main/java/org/apache/oozie/command/wf/ActionEndXCommand.java
@@ -140,10 +140,6 @@ protected Void execute() throws CommandException {
"End, name [{0}] type [{1}] status[{2}] external status [{3}] signal value [{4}]",
wfAction.getName(), wfAction.getType(), wfAction.getStatus(), wfAction.getExternalStatus(),
wfAction.getSignalValue());
- WorkflowInstance wfInstance = wfJob.getWorkflowInstance();
- DagELFunctions.setActionInfo(wfInstance, wfAction);
- wfJob.setWorkflowInstance(wfInstance);
- incrActionCounter(wfAction.getType(), 1);
Instrumentation.Cron cron = new Instrumentation.Cron();
cron.start();
@@ -151,6 +147,11 @@ protected Void execute() throws CommandException {
cron.stop();
addActionCron(wfAction.getType(), cron);
+ WorkflowInstance wfInstance = wfJob.getWorkflowInstance();
+ DagELFunctions.setActionInfo(wfInstance, wfAction);
+ wfJob.setWorkflowInstance(wfInstance);
+ incrActionCounter(wfAction.getType(), 1);
+
if (!context.isEnded()) {
LOG.warn(XLog.OPS, "Action Ended, ActionExecutor [{0}] must call setEndData()",
executor.getType());
Please sign in to comment.
Something went wrong with that request. Please try again.