Add explicit unit type

markhamstra · Dec 17, 2014 · 52247f5 · 52247f5
1 parent be42bcf
commit 52247f5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/ContextWaiter.scala b/streaming/src/main/scala/org/apache/spark/streaming/ContextWaiter.scala
@@ -31,7 +31,7 @@ private[streaming] class ContextWaiter {
   // Guarded by "lock"
   private var stopped: Boolean = false
 
-  def notifyError(e: Throwable) = {
+  def notifyError(e: Throwable): Unit = {
     lock.lock()
     try {
       error = e
@@ -41,7 +41,7 @@ private[streaming] class ContextWaiter {
     }
   }
 
-  def notifyStop() = {
+  def notifyStop(): Unit = {
     lock.lock()
     try {
       stopped = true