Repository: oozie Updated Branches: refs/heads/branch-4.1 7faaf4038 -> a8381b7dc
OOZIE-2005 Coordinator rerun fails to initialize error code and message (ryota) Project: http://git-wip-us.apache.org/repos/asf/oozie/repo Commit: http://git-wip-us.apache.org/repos/asf/oozie/commit/a8381b7d Tree: http://git-wip-us.apache.org/repos/asf/oozie/tree/a8381b7d Diff: http://git-wip-us.apache.org/repos/asf/oozie/diff/a8381b7d Branch: refs/heads/branch-4.1 Commit: a8381b7dc4b9bf815696aefbfa210b75dc5176d9 Parents: 7faaf40 Author: egashira <[email protected]> Authored: Wed Oct 15 12:03:49 2014 -0700 Committer: egashira <[email protected]> Committed: Wed Oct 15 12:03:49 2014 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/oozie/CoordinatorActionBean.java | 2 +- .../org/apache/oozie/command/coord/CoordRerunXCommand.java | 2 ++ .../apache/oozie/executor/jpa/CoordActionQueryExecutor.java | 2 ++ .../main/java/org/apache/oozie/store/CoordinatorStore.java | 4 ++-- .../apache/oozie/command/coord/TestCoordRerunXCommand.java | 7 +++++++ release-log.txt | 1 + 6 files changed, 15 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oozie/blob/a8381b7d/core/src/main/java/org/apache/oozie/CoordinatorActionBean.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/CoordinatorActionBean.java b/core/src/main/java/org/apache/oozie/CoordinatorActionBean.java index 795bf63..69724e2 100644 --- a/core/src/main/java/org/apache/oozie/CoordinatorActionBean.java +++ b/core/src/main/java/org/apache/oozie/CoordinatorActionBean.java @@ -74,7 +74,7 @@ import org.json.simple.JSONObject; @NamedQuery(name = "UPDATE_COORD_ACTION_FOR_MODIFIED_DATE", query = "update CoordinatorActionBean w set w.lastModifiedTimestamp = :lastModifiedTime where w.id = :id"), - @NamedQuery(name = "UPDATE_COORD_ACTION_RERUN", query = "update CoordinatorActionBean w set w.actionXml =:actionXml, w.statusStr = :status, w.externalId = :externalId, w.externalStatus = :externalStatus, w.rerunTimestamp = :rerunTime, w.lastModifiedTimestamp = :lastModifiedTime, w.createdTimestamp = :createdTime, w.createdConf = :createdConf, w.runConf = :runConf, w.missingDependencies = :missingDependencies, w.pushMissingDependencies = :pushMissingDependencies where w.id = :id"), + @NamedQuery(name = "UPDATE_COORD_ACTION_RERUN", query = "update CoordinatorActionBean w set w.actionXml =:actionXml, w.statusStr = :status, w.externalId = :externalId, w.externalStatus = :externalStatus, w.rerunTimestamp = :rerunTime, w.lastModifiedTimestamp = :lastModifiedTime, w.createdTimestamp = :createdTime, w.createdConf = :createdConf, w.runConf = :runConf, w.missingDependencies = :missingDependencies, w.pushMissingDependencies = :pushMissingDependencies, w.errorCode = :errorCode, w.errorMessage = :errorMessage where w.id = :id"), @NamedQuery(name = "DELETE_COMPLETED_ACTIONS_FOR_COORDINATOR", query = "delete from CoordinatorActionBean a where a.jobId = :jobId and (a.statusStr = 'SUCCEEDED' OR a.statusStr = 'FAILED' OR a.statusStr= 'KILLED')"), http://git-wip-us.apache.org/repos/asf/oozie/blob/a8381b7d/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java b/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java index 735b295..f7e498d 100644 --- a/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/coord/CoordRerunXCommand.java @@ -201,6 +201,8 @@ public class CoordRerunXCommand extends RerunTransitionXCommand<CoordinatorActio coordAction.setExternalStatus(null); coordAction.setRerunTime(new Date()); coordAction.setLastModifiedTime(new Date()); + coordAction.setErrorCode(""); + coordAction.setErrorMessage(""); updateList.add(new UpdateEntry<CoordActionQuery>(CoordActionQuery.UPDATE_COORD_ACTION_RERUN, coordAction)); writeActionRegistration(coordAction.getActionXml(), coordAction, coordJob.getUser(), coordJob.getGroup()); } http://git-wip-us.apache.org/repos/asf/oozie/blob/a8381b7d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionQueryExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionQueryExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionQueryExecutor.java index cd26e07..53c20a1 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionQueryExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionQueryExecutor.java @@ -146,6 +146,8 @@ public class CoordActionQueryExecutor extends query.setParameter("runConf", actionBean.getRunConfBlob()); query.setParameter("missingDependencies", actionBean.getMissingDependenciesBlob()); query.setParameter("pushMissingDependencies", actionBean.getPushMissingDependenciesBlob()); + query.setParameter("errorCode", actionBean.getErrorCode()); + query.setParameter("errorMessage", actionBean.getErrorMessage()); query.setParameter("id", actionBean.getId()); break; http://git-wip-us.apache.org/repos/asf/oozie/blob/a8381b7d/core/src/main/java/org/apache/oozie/store/CoordinatorStore.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/store/CoordinatorStore.java b/core/src/main/java/org/apache/oozie/store/CoordinatorStore.java index 9021778..25d4e41 100644 --- a/core/src/main/java/org/apache/oozie/store/CoordinatorStore.java +++ b/core/src/main/java/org/apache/oozie/store/CoordinatorStore.java @@ -684,8 +684,8 @@ public class CoordinatorStore extends Store { action.setActionXmlBlob(a.getActionXmlBlob()); action.setConsoleUrl(a.getConsoleUrl()); action.setCreatedConfBlob(a.getCreatedConfBlob()); - // action.setErrorCode(a.getErrorCode()); - // action.setErrorMessage(a.getErrorMessage()); + action.setErrorCode(a.getErrorCode()); + action.setErrorMessage(a.getErrorMessage()); action.setExternalStatus(a.getExternalStatus()); action.setMissingDependenciesBlob(a.getMissingDependenciesBlob()); action.setRunConfBlob(a.getRunConfBlob()); http://git-wip-us.apache.org/repos/asf/oozie/blob/a8381b7d/core/src/test/java/org/apache/oozie/command/coord/TestCoordRerunXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/test/java/org/apache/oozie/command/coord/TestCoordRerunXCommand.java b/core/src/test/java/org/apache/oozie/command/coord/TestCoordRerunXCommand.java index 92b2190..b736e77 100644 --- a/core/src/test/java/org/apache/oozie/command/coord/TestCoordRerunXCommand.java +++ b/core/src/test/java/org/apache/oozie/command/coord/TestCoordRerunXCommand.java @@ -856,6 +856,8 @@ public class TestCoordRerunXCommand extends XDataTestCase { CoordinatorStore store2 = Services.get().get(StoreService.class).getStore(CoordinatorStore.class); CoordinatorActionBean action2 = store2.getCoordinatorAction(actionId, false); assertEquals(action2.getStatus(), CoordinatorAction.Status.WAITING); + assertEquals(action2.getErrorCode(), ""); + assertEquals(action2.getErrorMessage(), ""); } /** @@ -1104,6 +1106,11 @@ public class TestCoordRerunXCommand extends XDataTestCase { action.setCreatedConf(createdConf); + if (status.equals(CoordinatorAction.Status.FAILED)) { + action.setErrorCode("E1000"); + action.setErrorMessage("Error"); + } + try { store.insertCoordinatorAction(action); } http://git-wip-us.apache.org/repos/asf/oozie/blob/a8381b7d/release-log.txt ---------------------------------------------------------------------- diff --git a/release-log.txt b/release-log.txt index b30e0c1..b651b2c 100644 --- a/release-log.txt +++ b/release-log.txt @@ -1,5 +1,6 @@ -- Oozie 4.1.0 release (4.1 - unreleased) +OOZIE-2005 Coordinator rerun fails to initialize error code and message (ryota) OOZIE-2019 SLA miss processed on server2 not send email (puru) OOZIE-2026 fix synchronization in SLACalculatorMemory.addJobStatus to avoid duplicated SLA message (ryota) OOZIE-2017 On startup, StatusTransitService can transition Coordinators that were in PREPSUSPENDED to RUNNING (rkanter)
