From 4b66488e4672c9da36fc6843b0247aec7d9322f4 Mon Sep 17 00:00:00 2001 From: Patrick Pisciuneri Date: Wed, 4 Apr 2018 11:37:03 -0400 Subject: [PATCH 1/2] use getCount in logWarning --- .../main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala b/core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala index 7e14938acd8e0..69c193e0dc45d 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala @@ -166,7 +166,7 @@ private class AsyncEventQueue(val name: String, conf: SparkConf, metrics: LiveLi val prevLastReportTimestamp = lastReportTimestamp lastReportTimestamp = System.currentTimeMillis() val previous = new java.util.Date(prevLastReportTimestamp) - logWarning(s"Dropped $droppedEvents events from $name since $previous.") + logWarning(s"Dropped ${droppedEvents.getCount} events from $name since $previous.") } } } From 3ad2f4298e290b3ce23533f04567bbd1fb096025 Mon Sep 17 00:00:00 2001 From: Patrick Pisciuneri Date: Wed, 4 Apr 2018 12:18:17 -0400 Subject: [PATCH 2/2] droppedEvents.getCount -> droppedCount --- .../main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala b/core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala index 69c193e0dc45d..c1fedd63f6a90 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/AsyncEventQueue.scala @@ -166,7 +166,7 @@ private class AsyncEventQueue(val name: String, conf: SparkConf, metrics: LiveLi val prevLastReportTimestamp = lastReportTimestamp lastReportTimestamp = System.currentTimeMillis() val previous = new java.util.Date(prevLastReportTimestamp) - logWarning(s"Dropped ${droppedEvents.getCount} events from $name since $previous.") + logWarning(s"Dropped $droppedCount events from $name since $previous.") } } }