diff --git a/core/src/main/java/org/apache/oozie/command/wf/WorkflowXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/WorkflowXCommand.java index 7fdf8695fd..642609ccbe 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/WorkflowXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/WorkflowXCommand.java @@ -85,6 +85,7 @@ protected void generateEvent(WorkflowActionBean wfAction, String wfUser) { wfAction.getStatus(), wfUser, wfAction.getName(), wfAction.getStartTime(), wfAction.getEndTime()); event.setErrorCode(wfAction.getErrorCode()); event.setErrorMessage(wfAction.getErrorMessage()); + event.setHadoopId(wfAction.getExternalId()); getEventService().queueEvent(event); } }