-
- Downloads
[SPARK-11511][STREAMING] Fix NPE when an InputDStream is not used
Just ignored `InputDStream`s that have null `rememberDuration` in `DStreamGraph.getMaxInputStreamRememberDuration`. Author: Shixiong Zhu <shixiong@databricks.com> Closes #9476 from zsxwing/SPARK-11511.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/DStreamGraph.scala 2 additions, 1 deletion.../main/scala/org/apache/spark/streaming/DStreamGraph.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala 16 additions, 0 deletions...la/org/apache/spark/streaming/StreamingContextSuite.scala
Loading
Please register or sign in to comment