diff --git a/src/main/java/com/loafle/overflow/container/service/ContainerCollectorService.java b/src/main/java/com/loafle/overflow/container/service/ContainerCollectorService.java index 387b1d9..e3d2be7 100644 --- a/src/main/java/com/loafle/overflow/container/service/ContainerCollectorService.java +++ b/src/main/java/com/loafle/overflow/container/service/ContainerCollectorService.java @@ -87,6 +87,7 @@ public class ContainerCollectorService implements CollectorService { logger.error("Cannot get data from crawler[%s] %s", sensorConfig.getCrawler().getName(), e.getMessage()); } }; + this.removeSchedule(sensorConfig.getConfigID()); ScheduledFuture sf = this.scheduledExecutorService.scheduleWithFixedDelay(task, 0, interval, TimeUnit.SECONDS); this.scheduleMap.put(sensorConfig.getConfigID(), sf); }