diff --git a/docs/configuration.md b/docs/configuration.md index 47b556bd3fd94..8e1c47c330ea6 100644 --- a/docs/configuration.md +++ b/docs/configuration.md @@ -1482,7 +1482,7 @@ Apart from these, the following properties are also available, and may be useful
spark.streamingListeners
spark.streaming.listeners
StreamingListener
; when initializing
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala b/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala
index bdf30120d5503..fb44f73fb634d 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala
@@ -530,13 +530,13 @@ class StreamingContext private[streaming] (
}
/**
- * Registers streamingListeners specified in spark.streamingListeners
+ * Registers streamingListeners specified in spark.streaming.listeners
*/
private def setupStreamingListeners(): Unit = {
// Use reflection to instantiate listeners specified via `spark.extraListeners`
try {
val listenerClassNames: Seq[String] =
- conf.get("spark.streamingListeners", "").split(',').map(_.trim).filter(_ != "")
+ conf.get("spark.streaming.listeners", "").split(',').map(_.trim).filter(_ != "")
for (className <- listenerClassNames) {
// Use reflection to find the right constructor
val constructors = {