diff --git a/src/main/java/gc/mda/signal_batch/batch/job/VesselBatchScheduler.java b/src/main/java/gc/mda/signal_batch/batch/job/VesselBatchScheduler.java index ab8fb31..c1dbf5d 100644 --- a/src/main/java/gc/mda/signal_batch/batch/job/VesselBatchScheduler.java +++ b/src/main/java/gc/mda/signal_batch/batch/job/VesselBatchScheduler.java @@ -162,7 +162,7 @@ public class VesselBatchScheduler { JobParameters params = new JobParametersBuilder() .addString("startTime", startTime.toString()) .addString("endTime", endTime.toString()) - .addString("timeBucket", "hourly") + .addString("timeBucket", startTime.toString()) .addString("executionTime", now.toString()) .addString("enableAbnormalDetection", String.valueOf(abnormalDetectionEnabled)) .toJobParameters();