IGNITE-8869 Exclude daemon's nodes from ExchangeLatch. Signed-off-by: Andrey Gura <[email protected]>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/219c9831 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/219c9831 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/219c9831 Branch: refs/heads/ignite-8446 Commit: 219c983122c513ec64cd5b1fc416388bb14c544c Parents: ba86183 Author: Ivan Daschinskiy <[email protected]> Authored: Mon Jul 9 19:22:15 2018 +0300 Committer: Andrey Gura <[email protected]> Committed: Mon Jul 9 19:22:15 2018 +0300 ---------------------------------------------------------------------- .../distributed/dht/preloader/latch/ExchangeLatchManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/219c9831/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java index 33c0861..2573251 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/latch/ExchangeLatchManager.java @@ -245,7 +245,8 @@ public class ExchangeLatchManager { Collection<ClusterNode> histNodes = discovery.topology(topVer.topologyVersion()); if (histNodes != null) - return histNodes.stream().filter(n -> !CU.clientNode(n) && discovery.alive(n)).collect(Collectors.toSet()); + return histNodes.stream().filter(n -> !CU.clientNode(n) && !n.isDaemon() && discovery.alive(n)) + .collect(Collectors.toSet()); else throw new IgniteException("Topology " +topVer + " not found in discovery history " + "; consider increasing IGNITE_DISCOVERY_HISTORY_SIZE property. Current value is "
