Fixed casting bug.

tdas · tdas · commit 19aec7d35c51 · 2014-10-30T18:22:15.000-07:00
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReceiverInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/ReceiverInputDStream.scala
@@ -59,7 +59,7 @@ abstract class ReceiverInputDStream[T: ClassTag](@transient ssc_ : StreamingCont
     val blockRDD = {
       if (validTime >= graph.startTime) {
         val blockStoreResults = getReceivedBlockInfo(validTime).map { _.blockStoreResult }
-        val blockIds = blockStoreResults.map { _.asInstanceOf[BlockId] }.toArray
+        val blockIds = blockStoreResults.map { _.blockId.asInstanceOf[BlockId] }.toArray
         val isWriteAheadLogBased = blockStoreResults.forall {
           _.isInstanceOf[WriteAheadLogBasedStoreResult]
         }

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ abstract class ReceiverInputDStream[T: ClassTag](@transient ssc_ : StreamingCont`
`59`	`59`	`val blockRDD = {`
`60`	`60`	`if (validTime >= graph.startTime) {`
`61`	`61`	`val blockStoreResults = getReceivedBlockInfo(validTime).map { _.blockStoreResult }`
`62`		`- val blockIds = blockStoreResults.map { _.asInstanceOf[BlockId] }.toArray`
	`62`	`+ val blockIds = blockStoreResults.map { _.blockId.asInstanceOf[BlockId] }.toArray`
`63`	`63`	`val isWriteAheadLogBased = blockStoreResults.forall {`
`64`	`64`	`_.isInstanceOf[WriteAheadLogBasedStoreResult]`
`65`	`65`	`}`