Decrement

tedyu · tedyu · commit cd9b2f2b8e2c · 2015-11-15T18:24:15.000-08:00
diff --git a/core/src/main/scala/org/apache/spark/util/AsynchronousListenerBus.scala b/core/src/main/scala/org/apache/spark/util/AsynchronousListenerBus.scala
@@ -78,7 +78,7 @@ private[spark] abstract class AsynchronousListenerBus[L <: AnyRef, E](name: Stri
           val event = eventQueue.poll
           assert(event != null, "event queue was empty but the listener bus was not stopped")
           if (eventLimit > 0) {
-            eventLimit--
+            eventLimit-=1
           }
           postToAll(event)
         } finally {

Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ private[spark] abstract class AsynchronousListenerBus[L <: AnyRef, E](name: Stri`
`78`	`78`	`val event = eventQueue.poll`
`79`	`79`	`assert(event != null, "event queue was empty but the listener bus was not stopped")`
`80`	`80`	`if (eventLimit > 0) {`
`81`		`- eventLimit--`
	`81`	`+ eventLimit-=1`
`82`	`82`	`}`
`83`	`83`	`postToAll(event)`
`84`	`84`	`} finally {`