We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5668a79 commit cde889eCopy full SHA for cde889e
extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala
@@ -243,7 +243,7 @@ abstract class KinesisStreamTests(aggregateTestData: Boolean) extends KinesisFun
243
kinesisStream.foreachRDD((rdd: RDD[Array[Byte]], time: Time) => {
244
val kRdd = rdd.asInstanceOf[KinesisBackedBlockRDD[Array[Byte]]]
245
val data = rdd.map { bytes => new String(bytes).toInt }.collect().toSeq
246
- collectedData.put(time,(kRdd.arrayOfseqNumberRanges, data))
+ collectedData.put(time, (kRdd.arrayOfseqNumberRanges, data))
247
})
248
249
ssc.remember(Minutes(60)) // remember all the batches so that they are all saved in checkpoint
0 commit comments