From b42765b4eb99be4433613bb049ebec11aeeff972 Mon Sep 17 00:00:00 2001 From: Stanislav Trailov Date: Mon, 17 Jun 2024 09:23:56 +0300 Subject: [PATCH] handle error when iterating over active rollouts! (#1747) * handle error when iterating over active rollouts! Signed-off-by: TRS1SF3 * fix typo and message Signed-off-by: TRS1SF3 --------- Signed-off-by: TRS1SF3 --- .../eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java index fa35c713b..a6595c35a 100644 --- a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java +++ b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java @@ -80,7 +80,12 @@ public class JpaRolloutHandler implements RolloutHandler { try { log.trace("Trigger handling {} rollouts.", rollouts.size()); - rollouts.forEach(rolloutId -> handleRolloutInNewTransaction(rolloutId, handlerId)); + rollouts.forEach(rolloutId -> { + try { + handleRolloutInNewTransaction(rolloutId, handlerId); + } catch (final Throwable throwable) { + log.error("Failed to process rollout with id {}", rolloutId , throwable); + }}); } finally { if (log.isTraceEnabled()) { log.trace("Unlock lock {}", lock);