Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/19211#discussion_r139594602
--- 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 --
why this change?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
