Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19211#discussion_r139749744
--- Diff:
streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala
---
@@ -575,8 +575,6 @@ class StreamingContextSuite extends SparkFunSuite with
BeforeAndAfter with TimeL
test("getActive and getActiveOrCreate") {
require(StreamingContext.getActive().isEmpty, "context exists from
before")
- sc = new SparkContext(conf)
--- End diff --
Because the test stops the underlying streaming context and thus the spark
context, and you can't add listeners to the bus after that. Thus, it was
failing.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
