You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@falcon.apache.org by aj...@apache.org on 2015/08/18 12:16:24 UTC
[1/2] falcon git commit: FALCON-1330 When multiple cluster
definitions exist for the same colo,
triage produces unexpected results. Contributed by Ajay Yadava.
Repository: falcon
Updated Branches:
refs/heads/master d8adca9d9 -> 1591e49e2
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/81c07f61
Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/81c07f61
Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/81c07f61
Branch: refs/heads/master
Commit: 81c07f61b70c43fe9767b5522e2ef06160708a9f
Parents: d8adca9
Author: Ajay Yadava <aj...@gmail.com>
Authored: Tue Aug 18 14:46:33 2015 +0530
Committer: Ajay Yadava <aj...@gmail.com>
Committed: Tue Aug 18 14:47:54 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/81c07f61/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/81c07f61/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));
}
[2/2] falcon git commit: FALCON-1344 EntityGraph returns null in list
of dependent entities. Contributed by Ajay Yadava.
Posted by aj...@apache.org.
FALCON-1344 EntityGraph returns null in list of dependent entities. 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/1591e49e
Tree: http://git-wip-us.apache.org/repos/asf/falcon/tree/1591e49e
Diff: http://git-wip-us.apache.org/repos/asf/falcon/diff/1591e49e
Branch: refs/heads/master
Commit: 1591e49e2f84019a48b9b6a25a992f072bc923fd
Parents: 81c07f6
Author: Ajay Yadava <aj...@gmail.com>
Authored: Tue Aug 18 14:59:53 2015 +0530
Committer: Ajay Yadava <aj...@gmail.com>
Committed: Tue Aug 18 15:13:20 2015 +0530
----------------------------------------------------------------------
CHANGES.txt | 2 ++
.../java/org/apache/falcon/entity/v0/EntityGraph.java | 12 ++++++++----
2 files changed, 10 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/falcon/blob/1591e49e/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 554cfea..23d7cf0 100755
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -89,6 +89,8 @@ Trunk (Unreleased)
(Suhas Vasu)
BUG FIXES
+ FALCON-1344 EntityGraph returns null in list of dependent entities(Ajay Yadava)
+
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)
http://git-wip-us.apache.org/repos/asf/falcon/blob/1591e49e/common/src/main/java/org/apache/falcon/entity/v0/EntityGraph.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/falcon/entity/v0/EntityGraph.java b/common/src/main/java/org/apache/falcon/entity/v0/EntityGraph.java
index 444e28d..bd4c6cf 100644
--- a/common/src/main/java/org/apache/falcon/entity/v0/EntityGraph.java
+++ b/common/src/main/java/org/apache/falcon/entity/v0/EntityGraph.java
@@ -60,8 +60,11 @@ public final class EntityGraph implements ConfigurationChangeListener {
Set<Entity> dependents = new HashSet<Entity>();
for (Node node : graph.get(entityNode)) {
Entity dependentEntity = store.get(node.type, node.name);
- assert dependentEntity != null : "Unable to find " + node;
- dependents.add(dependentEntity);
+ if (dependentEntity != null) {
+ dependents.add(dependentEntity);
+ } else {
+ LOG.error("Dependent entity {} was not found in configuration store.", node);
+ }
}
return dependents;
} else {
@@ -84,16 +87,17 @@ public final class EntityGraph implements ConfigurationChangeListener {
if (nodeEdges == null) {
return;
}
- LOG.trace("Adding edges for {}: {}", entity.getName(), nodeEdges);
+ LOG.debug("Adding edges for {}: {}", entity.getName(), nodeEdges);
for (Map.Entry<Node, Set<Node>> entry : nodeEdges.entrySet()) {
+ LOG.debug("Adding edges : {} for {}", entry.getValue(), entry.getKey());
if (graph.containsKey(entry.getKey())) {
graph.get(entry.getKey()).addAll(entry.getValue());
} else {
graph.put(entry.getKey(), entry.getValue());
}
}
- LOG.trace("Merged edges to graph {}", entity.getName());
+ LOG.debug("Merged edges to graph {}", entity.getName());
}
@Override