brooklyn-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From henev...@apache.org
Subject brooklyn-library git commit: minor fix to riak checking
Date Sat, 05 Mar 2016 00:56:07 GMT
Repository: brooklyn-library
Updated Branches:
  refs/heads/master cbb58b9ba -> 6efb209a4


minor fix to riak checking


Project: http://git-wip-us.apache.org/repos/asf/brooklyn-library/repo
Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-library/commit/6efb209a
Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-library/tree/6efb209a
Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-library/diff/6efb209a

Branch: refs/heads/master
Commit: 6efb209a4f6d5e2d0286429869e3460311a0acdd
Parents: cbb58b9
Author: Alex Heneveld <alex.heneveld@cloudsoftcorp.com>
Authored: Sat Mar 5 00:55:52 2016 +0000
Committer: Alex Heneveld <alex.heneveld@cloudsoftcorp.com>
Committed: Sat Mar 5 00:55:52 2016 +0000

----------------------------------------------------------------------
 .../java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/brooklyn-library/blob/6efb209a/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java
----------------------------------------------------------------------
diff --git a/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java
b/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java
index 8272815..3065015 100644
--- a/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java
+++ b/software/nosql/src/main/java/org/apache/brooklyn/entity/nosql/riak/RiakClusterImpl.java
@@ -204,6 +204,7 @@ public class RiakClusterImpl extends DynamicClusterImpl implements RiakCluster
{
                     DependentConfiguration.attributeWhenReady(member, RiakNode.RIAK_NODE_HAS_JOINED_CLUSTER,
Predicates.equalTo(false)).blockUntilEnded(Duration.TWO_MINUTES);
                     @SuppressWarnings("unchecked")
                     Optional<Entity> anyNodeInCluster = Iterables.tryFind(nodes.keySet(),
Predicates.and(
+                            EntityPredicates.isManaged(),
                             Predicates.instanceOf(RiakNode.class),
                             EntityPredicates.attributeEqualTo(RiakNode.RIAK_NODE_HAS_JOINED_CLUSTER,
true),
                             Predicates.not(Predicates.equalTo(member))));


Mime
View raw message