FALCON-1330 When multiple cluster definitions exist for the same colo, triage produces unexpected results. Contributed by Ajay Yadava.
Project: http://git-wip-us.apache.org/repos/asf/falcon/repo Commit: http://git-wip-us.apache.org/repos/asf/falcon/commit/3201e8d9 Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/3201e8d9 Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/3201e8d9 Branch: refs/heads/0.7 Commit: 3201e8d99956752648fa0d3f9245c106e4c370f8 Parents: 914c09f Author: Ajay Yadava <[email protected]> Authored: Tue Aug 18 14:46:33 2015 +0530 Committer: Ajay Yadava <[email protected]> Committed: Thu Aug 20 19:49:01 2015 +0530 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ .../java/org/apache/falcon/resource/AbstractInstanceManager.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/falcon/blob/3201e8d9/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index fda428e..554cfea 100755 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -89,6 +89,8 @@ Trunk (Unreleased) (Suhas Vasu) BUG FIXES + FALCON-1330 When multiple cluster definitions exist for the same colo, triage produces unexpected results(Ajay Yadava) + FALCON-1399 Property for default number of results is not loaded dynamically(Ajay Yadava) FALCON-1398 CrossEntityValidations contains incorrect validations(Pragya Mittal via Ajay Yadava) http://git-wip-us.apache.org/repos/asf/falcon/blob/3201e8d9/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java ---------------------------------------------------------------------- diff --git a/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java b/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java index ab8a2fd..c1b4da6 100644 --- a/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java +++ b/prism/src/main/java/org/apache/falcon/resource/AbstractInstanceManager.java @@ -647,7 +647,7 @@ public abstract class AbstractInstanceManager extends AbstractEntityManager { Entity entity = EntityUtil.getEntity(type, entityName); TriageResult result = new TriageResult(APIResult.Status.SUCCEEDED, "Success"); List<LineageGraphResult> triageGraphs = new LinkedList<>(); - for (String clusterName : DeploymentUtil.getCurrentClusters()) { + for (String clusterName : EntityUtil.getClustersDefinedInColos(entity)) { Cluster cluster = EntityUtil.getEntity(EntityType.CLUSTER, clusterName); triageGraphs.add(triage(type, entity, instanceTime, cluster)); }
