diff --git a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala index 3cc033426175a..bebf62f5744b3 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala @@ -142,7 +142,7 @@ class StreamingListenerSuite extends TestSuiteBase with Matchers { true } - test("registering listeners via spark.streaming.listeners") { + test("registering listeners via spark.streaming.extraListeners") { val conf = new SparkConf().setMaster("local").setAppName("test") .set("spark.streaming.extraListeners", classOf[BatchInfoCollector].getName + "," + classOf[ReceiverInfoCollector].getName)