This is an automated email from the ASF dual-hosted git repository.
namelchev 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 ff847ec15a3 IGNITE-19163 Added logging of snapshot check procedure
(#10825)
ff847ec15a3 is described below
commit ff847ec15a3fc1a52c76608dec5d15e6c23618d3
Author: Julia Bakulina <[email protected]>
AuthorDate: Fri Aug 4 11:01:02 2023 +0300
IGNITE-19163 Added logging of snapshot check procedure (#10825)
---
.../cache/persistence/snapshot/IgniteSnapshotManager.java | 10 ++++++++++
.../persistence/snapshot/SnapshotPartitionsVerifyTask.java | 6 ++++++
2 files changed, 16 insertions(+)
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java
index 780470bf2e2..58efd68bff2 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotManager.java
@@ -1834,6 +1834,11 @@ public class IgniteSnapshotManager extends
GridCacheSharedManagerAdapter
GridFutureAdapter<SnapshotPartitionsVerifyTaskResult> res = new
GridFutureAdapter<>();
+ if (log.isInfoEnabled()) {
+ log.info("The check snapshot procedure started [snpName=" + name +
", snpPath=" + snpPath +
+ ", incIdx=" + incIdx + ", grps=" + grps + ']');
+ }
+
GridKernalContext kctx0 = cctx.kernalContext();
Collection<ClusterNode> bltNodes =
F.view(cctx.discovery().serverNodes(AffinityTopologyVersion.NONE),
@@ -1952,6 +1957,11 @@ public class IgniteSnapshotManager extends
GridCacheSharedManagerAdapter
}
});
+ if (log.isInfoEnabled()) {
+ res.listen(f -> log.info("The check snapshot procedure finished
[snpName=" + name +
+ ", snpPath=" + snpPath + ", incIdx=" + incIdx + ", grps=" +
grps + ']'));
+ }
+
return res;
}
diff --git
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
index 2fc31021490..40fa00fcedf 100644
---
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
+++
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyTask.java
@@ -136,6 +136,12 @@ public class SnapshotPartitionsVerifyTask extends
AbstractSnapshotVerificationTa
catch (IgniteCheckedException | IOException e) {
throw new IgniteException(e);
}
+ finally {
+ if (log.isInfoEnabled()) {
+ log.info("Verify snapshot partitions procedure has been
finished " +
+ "[snpName=" + snpName + ", consId=" + consId + ']');
+ }
+ }
}
/** {@inheritDoc} */