Maintain consistancy with property naming conventions

apache · May 27, 2015 · d92d55b · d92d55b
1 parent 6453c90
commit d92d55b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
   </td>
 </tr>
 <tr>
-  <td><code>spark.streamingListeners</code></td>
+  <td><code>spark.streaming.listeners</code></td>
   <td>(none)</td>
   <td>
     A comma-separated list of classes that implement <code>StreamingListener</code>; 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
@@ -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 = {