diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/scheduler/ScheduledJobRunner.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/scheduler/ScheduledJobRunner.java index 4c9669b85d1..b29f54a2727 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/scheduler/ScheduledJobRunner.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/prelert/scheduler/ScheduledJobRunner.java @@ -97,6 +97,7 @@ public class ScheduledJobRunner extends AbstractComponent { } catch (Exception e) { logger.error("Failed lookback import for job [" + job.getId() + "]", e); holder.stop(e); + return; } if (next != null) { doScheduleRealtime(next, job.getId(), holder);