Skip to content

Commit 8dffdf0

Browse files
moved warning to outer catch block
1 parent 9f463da commit 8dffdf0

File tree

1 file changed

+5
-9
lines changed

1 file changed

+5
-9
lines changed

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotCheckProcess.java

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -254,19 +254,15 @@ private void reduceCustomHandlersResults(
254254
}
255255
}
256256

257-
try {
258-
kctx.cache().context().snapshotMgr().handlers().completeAll(
259-
SnapshotHandlerType.RESTORE, ctx.req.snapshotName(), clusterResults, execNodes, wrns -> {});
260-
}
261-
catch (Exception e) {
262-
log.warning("The snapshot operation will be aborted due to a handler error [snapshot=" + ctx.req.snapshotName() + "].", e);
263-
264-
throw new IgniteException(e);
265-
}
257+
kctx.cache().context().snapshotMgr().handlers().completeAll(
258+
SnapshotHandlerType.RESTORE, ctx.req.snapshotName(), clusterResults, execNodes, wrns -> {});
266259

267260
fut.onDone(new SnapshotPartitionsVerifyTaskResult(ctx.clusterMetas, null));
268261
}
269262
catch (Throwable err) {
263+
if (err instanceof Exception)
264+
log.warning("The snapshot operation will be aborted due to a handler error [snapshot=" + ctx.req.snapshotName() + "].", err);
265+
270266
fut.onDone(err);
271267
}
272268
}

0 commit comments

Comments
 (0)