Don't use hazelcast executor in task scheduling #10122

enonic · Apr 21, 2023 · dd72cf7 · dd72cf7
1 parent 6479f15
commit dd72cf7
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...core-scheduler/src/main/java/com/enonic/xp/impl/scheduler/distributed/RescheduleTask.java b/...core-scheduler/src/main/java/com/enonic/xp/impl/scheduler/distributed/RescheduleTask.java
@@ -85,7 +85,10 @@ private static void scheduleOneTimeJobs( final Map<ScheduledJobName, ScheduledJo
     private static void scheduleCronJobs( final Map<ScheduledJobName, ScheduledJob> jobs, final Instant now,
                                           final Predicate<ScheduledJob> filterAlreadyScheduled )
     {
-        jobs.values().stream().filter( ScheduledJob::isEnabled ).filter( filterAlreadyScheduled )
+        jobs.values()
+            .stream()
+            .filter( ScheduledJob::isEnabled )
+            .filter( filterAlreadyScheduled )
             .filter( job -> ScheduleCalendarType.CRON.equals( job.getCalendar().getType() ) )
             .forEach( job -> {
                 final Instant actualLastRun = job.getLastRun();
@@ -211,6 +214,7 @@ private void retryFailedJobs( final List<JobToRun> failedJobs )
             if ( entity.attempts < 10 )
             {
                 QUEUE.offer( new JobToRun( entity.name, entity.timeToRun, entity.attempts + 1 ) );
+                LOG.warn( "Error while running job [{}], will try to run once more", entity.name );
             }
             else
             {