Repository: ambari Updated Branches: refs/heads/trunk 1fb2aab41 -> 7a909ade9
AMBARI-15620 - Orphaned Host Alerts Cause Stale Alert Notifications After Removing Hosts (part2) (jonathanhurley) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/7a909ade Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/7a909ade Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/7a909ade Branch: refs/heads/trunk Commit: 7a909ade91da851d3b6910fe4f724f2dc23009c8 Parents: 1fb2aab Author: Jonathan Hurley <[email protected]> Authored: Thu Mar 31 10:44:04 2016 -0400 Committer: Jonathan Hurley <[email protected]> Committed: Thu Mar 31 10:47:21 2016 -0400 ---------------------------------------------------------------------- .../ambari/server/state/cluster/ClustersImpl.java | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/7a909ade/ambari-server/src/main/java/org/apache/ambari/server/state/cluster/ClustersImpl.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/state/cluster/ClustersImpl.java b/ambari-server/src/main/java/org/apache/ambari/server/state/cluster/ClustersImpl.java index 6c1e56e..0442e4e 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/state/cluster/ClustersImpl.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/state/cluster/ClustersImpl.java @@ -387,16 +387,11 @@ public class ClustersImpl implements Clusters { public boolean isHostMappedToCluster(String clusterName, String hostName) { checkLoaded(); - r.lock(); - try { - Set<Cluster> clusters = hostClusterMap.get(hostName); - for (Cluster cluster : clusters) { - if (clusterName.equals(cluster.getClusterName())) { - return true; - } + Set<Cluster> clusters = hostClusterMap.get(hostName); + for (Cluster cluster : clusters) { + if (clusterName.equals(cluster.getClusterName())) { + return true; } - } finally { - r.unlock(); } return false;
