Mmuzaf commented on a change in pull request #9105:
URL: https://github.com/apache/ignite/pull/9105#discussion_r638758425
##########
File path:
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotRestoreProcess.java
##########
@@ -184,90 +184,84 @@ protected void cleanup() throws IgniteCheckedException {
return new IgniteFinishedFutureImpl<>(e);
}
-
ctx.cache().context().snapshotMgr().collectSnapshotMetadata(snpName).listen(
- f -> {
- if (f.error() != null) {
- finishProcess(fut0.rqId, f.error());
+ ctx.cache().context().snapshotMgr().checkSnapshot(snpName,
cacheGrpNames).listen(f -> {
+ if (f.error() != null) {
+ finishProcess(fut0.rqId, f.error());
- return;
- }
+ return;
+ }
- Set<UUID> dataNodes = new HashSet<>();
- Set<String> snpBltNodes = null;
- Map<ClusterNode, List<SnapshotMetadata>> metas = f.result();
- Map<Integer, String> reqGrpIds = cacheGrpNames == null ?
Collections.emptyMap() :
-
cacheGrpNames.stream().collect(Collectors.toMap(CU::cacheId, v -> v));
+ if (!F.isEmpty(f.result().exceptions())) {
+ finishProcess(fut0.rqId,
F.firstEntry(f.result().exceptions()).getValue());
Review comment:
Fixed.
##########
File path:
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
##########
@@ -165,13 +175,19 @@
/** Consistent snapshot metadata file name. */
private final String consId;
+ /** Set of cache groups to be checked in the snapshot or {@code empty}
to check everything. */
+ private final Set<String> rqGrps = new HashSet<>();
+
/**
* @param snpName Snapshot name to validate.
* @param consId Consistent snapshot metadata file name.
*/
Review comment:
Fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
