diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-07-16 14:36:36 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-07-16 14:37:08 +0530 |
| commit | 55da6e9504c533b6eaced215c9d4a6199062f799 (patch) | |
| tree | 2588b2e14fd4992a02fc068b772e0eae54176a67 /streaming | |
| parent | ff14f38f3dce314eb1afb876e79cbab6b1c252b8 (diff) | |
| download | spark-55da6e9504c533b6eaced215c9d4a6199062f799.tar.gz spark-55da6e9504c533b6eaced215c9d4a6199062f799.tar.bz2 spark-55da6e9504c533b6eaced215c9d4a6199062f799.zip | |
Fixed warning erasure -> runtimeClass
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala index 8b23642e4a..47274f41a5 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala @@ -85,7 +85,7 @@ class KafkaReceiver[T: ClassTag, D <: Decoder[_]: Manifest]( } // Create Threads for each Topic/Message Stream we are listening - val decoder = manifest[D].erasure.newInstance.asInstanceOf[Decoder[T]] + val decoder = manifest[D].runtimeClass.newInstance.asInstanceOf[Decoder[T]] val topicMessageStreams = consumerConnector.createMessageStreams(topics, decoder) // Start the messages handler for each partition |