-
- Downloads
Made block generator thread safe to fix Kafka bug.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/dstream/NetworkInputDStream.scala 2 additions, 2 deletions.../apache/spark/streaming/dstream/NetworkInputDStream.scala
- streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala 78 additions, 5 deletions.../scala/org/apache/spark/streaming/InputStreamsSuite.scala
Loading
Please register or sign in to comment