-
- Downloads
[SPARK-13186][STREAMING] migrate away from SynchronizedMap
trait SynchronizedMap in package mutable is deprecated: Synchronization via traits is deprecated as it is inherently unreliable. Change to java.util.concurrent.ConcurrentHashMap instead. Author: Huaxin Gao <huaxing@us.ibm.com> Closes #11250 from huaxingao/spark__13186.
Showing
- external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala 7 additions, 6 deletions...a/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala
- extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala 21 additions, 17 deletions...g/apache/spark/streaming/kinesis/KinesisStreamSuite.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala 16 additions, 14 deletions...org/apache/spark/streaming/dstream/FileInputDStream.scala
- streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala 2 additions, 1 deletion...st/scala/org/apache/spark/streaming/CheckpointSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala 9 additions, 3 deletions...a/org/apache/spark/streaming/StreamingListenerSuite.scala
Loading
Please register or sign in to comment