IGNITE-544 - Fixing tests
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/987a5dc2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/987a5dc2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/987a5dc2 Branch: refs/heads/ignite-341 Commit: 987a5dc2d8dc1f4bea123f6777db11c93a45f796 Parents: 1424f9d Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Tue Mar 24 18:36:35 2015 -0700 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Tue Mar 24 18:36:35 2015 -0700 ---------------------------------------------------------------------- .../cache/distributed/dht/GridDhtAssignmentFetchFuture.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/987a5dc2/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java index 79628cc..303d649 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtAssignmentFetchFuture.java @@ -71,7 +71,12 @@ public class GridDhtAssignmentFetchFuture extends GridFutureAdapter<List<List<Cl this.topVer = topVer; LinkedList<ClusterNode> tmp = new LinkedList<>(); - tmp.addAll(availableNodes); + + for (ClusterNode node : availableNodes) { + if (!node.isLocal()) + tmp.add(node); + } + Collections.sort(tmp, GridNodeOrderComparator.INSTANCE); this.availableNodes = tmp;
