We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ec2b6c2 commit d904b25Copy full SHA for d904b25
streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobGenerator.scala
@@ -220,7 +220,8 @@ class JobGenerator(jobScheduler: JobScheduler) extends Logging {
220
logInfo("Batches pending processing (" + pendingTimes.size + " batches): " +
221
pendingTimes.mkString(", "))
222
// Reschedule jobs for these times
223
- val timesToReschedule = (pendingTimes ++ downTimes).distinct.sorted(Time.ordering)
+ val timesToReschedule = (pendingTimes ++ downTimes).filter { _ != restartTime }
224
+ .distinct.sorted(Time.ordering)
225
logInfo("Batches to reschedule (" + timesToReschedule.size + " batches): " +
226
timesToReschedule.mkString(", "))
227
timesToReschedule.foreach { time =>
0 commit comments