You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by mp...@apache.org on 2023/06/14 11:07:05 UTC
[ignite] branch master updated: IGNITE-19164 Removed node consistent ID from snapshot restore message (#10771)
This is an automated email from the ASF dual-hosted git repository.
mpetrov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new f6e03372967 IGNITE-19164 Removed node consistent ID from snapshot restore message (#10771)
f6e03372967 is described below
commit f6e033729676082fd7f81bff58e6915e5d40ba33
Author: Julia Bakulina <96...@users.noreply.github.com>
AuthorDate: Wed Jun 14 14:06:55 2023 +0300
IGNITE-19164 Removed node consistent ID from snapshot restore message (#10771)
---
.../processors/cache/persistence/snapshot/SnapshotRestoreProcess.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotRestoreProcess.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotRestoreProcess.java
index 3fb904755c1..f16543a4fa4 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotRestoreProcess.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotRestoreProcess.java
@@ -1127,7 +1127,6 @@ public class SnapshotRestoreProcess {
"[reqId=" + reqId +
", snapshot=" + opCtx0.snpName +
", nodeId=" + m.getKey() +
- ", consistentId=" + ctx.discovery().node(m.getKey()).consistentId() +
", grpParts=" + partitionsMapToString(m.getValue(), cacheGrpNames) + "]");
}
@@ -1860,7 +1859,8 @@ public class SnapshotRestoreProcess {
private String partitionsMapToString(Map<Integer, Set<Integer>> map, Map<Integer, String> cacheGrpNames) {
return map.entrySet()
.stream()
- .collect(Collectors.toMap(e -> String.format("{grpId=%d, grpName=%s}", e.getKey(), cacheGrpNames.get(e.getKey())),
+ .collect(Collectors.toMap(
+ e -> String.format("{grpId=%d, grpName=%s}", e.getKey(), cacheGrpNames.get(e.getKey())),
e -> S.toStringSortedDistinct(e.getValue())))
.toString();
}