SPARK-11193 - Cleanup return keyword in getLatestSeqNumToCheckpoint()…

… function
apache · Dec 11, 2015 · 5cec007 · 5cec007
1 parent 61221af
commit 5cec007
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -222,7 +222,7 @@ private[kinesis] class KinesisReceiver[T](
 
   /** Get the latest sequence number for the given shard that can be checkpointed through KCL */
   private[kinesis] def getLatestSeqNumToCheckpoint(shardId: String): Option[String] = {
-    return Option(shardIdToLatestStoredSeqNum.get(shardId))
+    Option(shardIdToLatestStoredSeqNum.get(shardId))
   }
 
   /**