diff options
| author | Patrick Wendell <patrick@databricks.com> | 2015-05-19 00:02:06 -0700 |
|---|---|---|
| committer | Patrick Wendell <patrick@databricks.com> | 2015-05-19 00:02:29 -0700 |
| commit | 23cf897112624ece19a3b5e5394cdf71b9c3c8b3 (patch) | |
| tree | 270d120380e29b2a3e4d1e4d59fa73a6ee1e85a0 /extras | |
| parent | 9ebb44f8abb1a13f045eed60190954db904ffef7 (diff) | |
| download | spark-23cf897112624ece19a3b5e5394cdf71b9c3c8b3.tar.gz spark-23cf897112624ece19a3b5e5394cdf71b9c3c8b3.tar.bz2 spark-23cf897112624ece19a3b5e5394cdf71b9c3c8b3.zip | |
[HOTFIX] Fixing style failures in Kinesis source
Diffstat (limited to 'extras')
2 files changed, 6 insertions, 4 deletions
diff --git a/extras/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala b/extras/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala index 640ca049e2..df77f4be9d 100644 --- a/extras/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala +++ b/extras/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala @@ -119,7 +119,8 @@ object KinesisWordCountASL extends Logging { val batchInterval = Milliseconds(2000) // Kinesis checkpoint interval is the interval at which the DynamoDB is updated with information - //on sequence number of records that have been received. Same as batchInterval for this example. + // on sequence number of records that have been received. Same as batchInterval for this + // example. val kinesisCheckpointInterval = batchInterval // Get the region name from the endpoint URL to save Kinesis Client Library metadata in @@ -173,7 +174,8 @@ object KinesisWordProducerASL { if (args.length != 4) { System.err.println( """ - |Usage: KinesisWordProducerASL <stream-name> <endpoint-url> <records-per-sec> <words-per-record> + |Usage: KinesisWordProducerASL <stream-name> <endpoint-url> <records-per-sec> + <words-per-record> | | <stream-name> is the name of the Kinesis stream | <endpoint-url> is the endpoint of the Kinesis service diff --git a/extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala b/extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala index 01608fbd3f..90164490ef 100644 --- a/extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala +++ b/extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala @@ -82,8 +82,8 @@ private[kinesis] class KinesisReceiver( */ /** - * workerId is used by the KCL should be based on the ip address of the actual Spark Worker where this code runs - * (not the driver's IP address.) + * workerId is used by the KCL should be based on the ip address of the actual Spark Worker + * where this code runs (not the driver's IP address.) */ private var workerId: String = null |