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 <[email protected]>
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();
}