diff --git a/hazelcast/src/main/java/com/hazelcast/jet/impl/SnapshotValidator.java b/hazelcast/src/main/java/com/hazelcast/jet/impl/SnapshotValidator.java index 9ccd453744e3..dfc5b7dca6b4 100644 --- a/hazelcast/src/main/java/com/hazelcast/jet/impl/SnapshotValidator.java +++ b/hazelcast/src/main/java/com/hazelcast/jet/impl/SnapshotValidator.java @@ -47,8 +47,8 @@ static long validateSnapshot( if (validationRecord == null) { String nameOrId = snapshotName != null ? '"' + snapshotName + '"' : "with ID " + snapshotId; throw new JetException(String.format( - "snapshot %s doesn't exist or is damaged. Unable to restore the state for %s.", - nameOrId, jobIdString)); + "snapshot %s in IMap %s (%d entries) is damaged. Unable to restore the state for %s.", + nameOrId, snapshotMap.getName(), snapshotMap.size() - 1, jobIdString)); } if (validationRecord.numChunks() != snapshotMap.size() - 1) { // fallback validation that counts using aggregate(), ignoring different snapshot IDs