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 be42bcf commit 52247f5Copy full SHA for 52247f5
streaming/src/main/scala/org/apache/spark/streaming/ContextWaiter.scala
@@ -31,7 +31,7 @@ private[streaming] class ContextWaiter {
31
// Guarded by "lock"
32
private var stopped: Boolean = false
33
34
- def notifyError(e: Throwable) = {
+ def notifyError(e: Throwable): Unit = {
35
lock.lock()
36
try {
37
error = e
@@ -41,7 +41,7 @@ private[streaming] class ContextWaiter {
41
}
42
43
44
- def notifyStop() = {
+ def notifyStop(): Unit = {
45
46
47
stopped = true
0 commit comments