spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pwend...@apache.org
Subject spark git commit: [HOTFIX] Fixing style failures in Kinesis source
Date Tue, 19 May 2015 07:02:34 GMT
Repository: spark
Updated Branches:
  refs/heads/master 9ebb44f8a -> 23cf89711


[HOTFIX] Fixing style failures in Kinesis source


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/23cf8971
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/23cf8971
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/23cf8971

Branch: refs/heads/master
Commit: 23cf897112624ece19a3b5e5394cdf71b9c3c8b3
Parents: 9ebb44f
Author: Patrick Wendell <patrick@databricks.com>
Authored: Tue May 19 00:02:06 2015 -0700
Committer: Patrick Wendell <patrick@databricks.com>
Committed: Tue May 19 00:02:29 2015 -0700

----------------------------------------------------------------------
 .../apache/spark/examples/streaming/KinesisWordCountASL.scala  | 6 ++++--
 .../org/apache/spark/streaming/kinesis/KinesisReceiver.scala   | 4 ++--
 2 files changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/23cf8971/extras/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala
----------------------------------------------------------------------
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 640ca04..df77f4b 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

http://git-wip-us.apache.org/repos/asf/spark/blob/23cf8971/extras/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala
----------------------------------------------------------------------
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 01608fb..9016449 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
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message