Skip to content

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also .

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also .
  • 2 commits
  • 1 file changed
  • 0 commit comments
  • 1 contributor
Showing with 5 additions and 2 deletions.
  1. +5 −2 oozie/src/main/java/org/apache/ivory/workflow/engine/OozieWorkflowEngine.java
View
7 oozie/src/main/java/org/apache/ivory/workflow/engine/OozieWorkflowEngine.java
@@ -171,6 +171,7 @@ private boolean isBundleInState(Entity entity, BundleStatus status)
private BundleJob findBundle(Entity entity, String cluster)
throws IvoryException {
String stPath = EntityUtil.getStagingPath(entity);
+ LOG.info("Staging path for entity " + stPath);
List<BundleJob> bundles = findBundles(entity, cluster);
for (BundleJob job : bundles) {
if (job.getAppPath().endsWith(stPath)) {
@@ -190,8 +191,10 @@ private BundleJob findBundle(Entity entity, String cluster)
if (jobs != null) {
List<BundleJob> filteredJobs = new ArrayList<BundleJob>();
for(BundleJob job : jobs)
- if(job.getStatus() != Job.Status.KILLED || job.getEndTime() == null)
+ if(job.getStatus() != Job.Status.KILLED || job.getEndTime() == null) {
filteredJobs.add(job);
+ LOG.debug("Found bundle " + job.getId());
+ }
return filteredJobs;
}
return new ArrayList<BundleJob>();
@@ -204,7 +207,6 @@ private BundleJob findBundle(Entity entity, String cluster)
throws IvoryException {
Set<String> clusters = EntityUtil.getClustersDefinedInColos(entity);
Map<String, List<BundleJob>> jobMap = new HashMap<String, List<BundleJob>>();
-
for (String cluster : clusters) {
jobMap.put(cluster, findBundles(entity, cluster));
}
@@ -885,6 +887,7 @@ private void updateCoords(String cluster, String bundleId, int concurrency,
private void suspend(String cluster, BundleJob bundle)
throws IvoryException {
+ bundle = getBundleInfo(cluster, bundle.getId());
for (CoordinatorJob coord : bundle.getCoordinators()) {
suspend(cluster, coord.getId());
}

No commit comments for this range

Something went wrong with that request. Please try again.