Dedup ScheduleStream by jobName. (#689)

mesos · Jun 21, 2016 · ce4469d · ce4469d
1 parent 2f12dcd
commit ce4469d
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/JobScheduler.scala b/src/main/scala/org/apache/mesos/chronos/scheduler/jobs/JobScheduler.scala
@@ -722,7 +722,13 @@ class JobScheduler @Inject()(val scheduleHorizon: Period,
     log.info("Adding schedule for time:" + now.toString(DateTimeFormat.fullTime()))
     lock.synchronized {
       log.fine("Starting iteration")
-      streams = iteration(now, newStreams ++ streams)
+      for(stream <- newStreams) {
+        if (!streams.exists(_.jobName == stream.jobName)) {
+          streams = streams :+ stream
+        }
+      }
+
+      streams = iteration(now, streams)
       log.fine("Size of streams: %d".format(streams.size))
     }
   }