Repository: ignite Updated Branches: refs/heads/master 51a202a4c -> 0f432e3fe
Log information about lost partitions. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/91d77a79 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/91d77a79 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/91d77a79 Branch: refs/heads/master Commit: 91d77a79c4805e501d8637fc1263866d5e914fba Parents: 7e547b1 Author: sboikov <[email protected]> Authored: Mon Oct 15 17:58:59 2018 +0300 Committer: sboikov <[email protected]> Committed: Mon Oct 15 17:58:59 2018 +0300 ---------------------------------------------------------------------- .../distributed/dht/topology/GridDhtPartitionTopologyImpl.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/91d77a79/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java index 8b5c028..94bb7f1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java @@ -2051,6 +2051,12 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology { } } + if (!recentlyLost.isEmpty()) { + U.warn(log, "Detected lost partitions [grp=" + grp.cacheOrGroupName() + + ", parts=" + S.compact(recentlyLost) + + ", plc=" + plc + "]"); + } + // Update partition state on all nodes. for (Integer part : lost) { long updSeq = updateSeq.incrementAndGet();
