From eb930b6eaeb685a8fd18948ef67a3e61a90c4edf Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Franti=C5=A1ek=20Hartman?= Date: Wed, 23 Feb 2022 17:52:41 +0100 Subject: [PATCH] Log map name when snapshot validation fails (#20822) --- .../main/java/com/hazelcast/jet/impl/SnapshotValidator.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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