diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-05-21 13:50:08 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-05-21 13:50:08 -0700 |
| commit | 311fab6f1b00db1a581d77be5196dd045f93d83d (patch) | |
| tree | 3f220b39791661fbf95e6959db75de6c6de952e3 /extras | |
| parent | cdc7c055c931c4c931a11b510de473455f3256da (diff) | |
| download | spark-311fab6f1b00db1a581d77be5196dd045f93d83d.tar.gz spark-311fab6f1b00db1a581d77be5196dd045f93d83d.tar.bz2 spark-311fab6f1b00db1a581d77be5196dd045f93d83d.zip | |
[SPARK-7722] [STREAMING] Added Kinesis to style checker
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #6325 from tdas/SPARK-7722 and squashes the following commits:
9ab35b2 [Tathagata Das] Fixed styles in Kinesis
Diffstat (limited to 'extras')
| -rw-r--r-- | extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisReceiverSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisReceiverSuite.scala b/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisReceiverSuite.scala index cd19c33b90..2103dca6b7 100644 --- a/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisReceiverSuite.scala +++ b/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisReceiverSuite.scala @@ -57,7 +57,7 @@ class KinesisReceiverSuite extends TestSuiteBase with Matchers with BeforeAndAft var checkpointStateMock: KinesisCheckpointState = _ var currentClockMock: Clock = _ - override def beforeFunction() = { + override def beforeFunction(): Unit = { receiverMock = mock[KinesisReceiver] checkpointerMock = mock[IRecordProcessorCheckpointer] checkpointClockMock = mock[ManualClock] |