-
- Downloads
[SPARK-7554] [STREAMING] Throw exception when an active/stopped...
[SPARK-7554] [STREAMING] Throw exception when an active/stopped StreamingContext is used to create DStreams and output operations Author: Tathagata Das <tathagata.das1565@gmail.com> Closes #6099 from tdas/SPARK-7554 and squashes the following commits: 2cd4158 [Tathagata Das] Throw exceptions on attempts to add stuff to active and stopped contexts.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/DStreamGraph.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/streaming/DStreamGraph.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala 19 additions, 2 deletions...in/scala/org/apache/spark/streaming/dstream/DStream.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala 39 additions, 0 deletions...la/org/apache/spark/streaming/StreamingContextSuite.scala
Loading
Please register or sign in to comment