Skip to content

Commit 682002b

Browse files
Patrick Pisciunericloud-fan
authored andcommitted
[SPARK-23867][SCHEDULER] use droppedCount in logWarning
## What changes were proposed in this pull request? Get the count of dropped events for output in log message. ## How was this patch tested? The fix is pretty trivial, but `./dev/run-tests` were run and were successful. Please review http://spark.apache.org/contributing.html before opening a pull request. vanzin cloud-fan The contribution is my original work and I license the work to the project under the project’s open source license. Author: Patrick Pisciuneri <[email protected]> Closes apache#20977 from phpisciuneri/fix-log-warning.
1 parent 0f93b91 commit 682002b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ private class AsyncEventQueue(val name: String, conf: SparkConf, metrics: LiveLi
166166
val prevLastReportTimestamp = lastReportTimestamp
167167
lastReportTimestamp = System.currentTimeMillis()
168168
val previous = new java.util.Date(prevLastReportTimestamp)
169-
logWarning(s"Dropped $droppedEvents events from $name since $previous.")
169+
logWarning(s"Dropped $droppedCount events from $name since $previous.")
170170
}
171171
}
172172
}

0 commit comments

Comments
 (0)