-
- Downloads
[streaming][SPARK-1578] Removed requirement for TTL in StreamingContext.
Since shuffles and RDDs that are out of context are automatically cleaned by Spark core (using ContextCleaner) there is no need for setting the cleaner TTL while creating a StreamingContext. Author: Tathagata Das <tathagata.das1565@gmail.com> Closes #491 from tdas/ttl-fix and squashes the following commits: cf01dc7 [Tathagata Das] Removed requirement for TTL in StreamingContext.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 1 addition, 14 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala 1 addition, 1 deletion.../scala/org/apache/spark/streaming/InputStreamsSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala 12 additions, 33 deletions...la/org/apache/spark/streaming/StreamingContextSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/TestSuiteBase.scala 0 additions, 1 deletion...test/scala/org/apache/spark/streaming/TestSuiteBase.scala
Loading
Please register or sign in to comment