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 b4f56a0 commit 2f47c30Copy full SHA for 2f47c30
core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala
@@ -141,8 +141,10 @@ private[spark] class LiveListenerBus(val sparkContext: SparkContext) extends Spa
141
// And if another thread is increasing droppedEventsCounter, "compareAndSet" will fail and
142
// then that thread will update it.
143
if (droppedEventsCounter.compareAndSet(droppedEvents, 0)) {
144
+ val prevLastReportTimestamp = lastReportTimestamp
145
lastReportTimestamp = System.currentTimeMillis()
- logWarning(s"Dropped $droppedEvents SparkListenerEvents")
146
+ logWarning(s"Dropped $droppedEvents SparkListenerEvents since " +
147
+ new java.util.Date(prevLastReportTimestamp))
148
}
149
150
0 commit comments