You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oozie.apache.org by ro...@apache.org on 2014/06/23 23:16:47 UTC
git commit: OOZIE-1893 Recovery service will never recover bundle
action if CoordSubmitXCommand command is lost (puru via rohini)
Repository: oozie
Updated Branches:
refs/heads/master db11ab356 -> b84a3e45c
OOZIE-1893 Recovery service will never recover bundle action if CoordSubmitXCommand command is lost (puru via rohini)
Project: http://git-wip-us.apache.org/repos/asf/oozie/repo
Commit: http://git-wip-us.apache.org/repos/asf/oozie/commit/b84a3e45
Tree: http://git-wip-us.apache.org/repos/asf/oozie/tree/b84a3e45
Diff: http://git-wip-us.apache.org/repos/asf/oozie/diff/b84a3e45
Branch: refs/heads/master
Commit: b84a3e45ce15e7deab260d2ca8afaa72e0bceddc
Parents: db11ab3
Author: Rohini Palaniswamy <ro...@apache.org>
Authored: Mon Jun 23 14:16:38 2014 -0700
Committer: Rohini Palaniswamy <ro...@apache.org>
Committed: Mon Jun 23 14:16:38 2014 -0700
----------------------------------------------------------------------
core/src/main/java/org/apache/oozie/service/RecoveryService.java | 2 +-
release-log.txt | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/oozie/blob/b84a3e45/core/src/main/java/org/apache/oozie/service/RecoveryService.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/oozie/service/RecoveryService.java b/core/src/main/java/org/apache/oozie/service/RecoveryService.java
index 2749bc4..b22a98d 100644
--- a/core/src/main/java/org/apache/oozie/service/RecoveryService.java
+++ b/core/src/main/java/org/apache/oozie/service/RecoveryService.java
@@ -183,7 +183,7 @@ public class RecoveryService implements Service {
log.error("CoordId is null for Bundle action " + baction.getBundleActionId());
continue;
}
- if (Services.get().get(JobsConcurrencyService.class).isJobIdForThisServer(baction.getCoordId())) {
+ if (Services.get().get(JobsConcurrencyService.class).isJobIdForThisServer(baction.getBundleId())) {
if (baction.getStatus() == Job.Status.PREP && baction.getCoordId() == null) {
BundleJobBean bundleJob = null;
if (jpaService != null) {
http://git-wip-us.apache.org/repos/asf/oozie/blob/b84a3e45/release-log.txt
----------------------------------------------------------------------
diff --git a/release-log.txt b/release-log.txt
index fef3453..5f4602b 100644
--- a/release-log.txt
+++ b/release-log.txt
@@ -1,5 +1,6 @@
-- Oozie 4.1.0 release (trunk - unreleased)
+OOZIE-1893 Recovery service will never recover bundle action if CoordSubmitXCommand command is lost (puru via rohini)
OOZIE-1878 Can't execute dryrun on the CLI (puru via rohini)
OOZIE-1741 Add new coord EL function to get input partitions value string (satish.mittal via rohini)
OOZIE-1817 Oozie timers are not biased (rkanter)