fixed typos and backward compatibility

Author: cfregly

docs/streaming-programming-guide.md

@@ -518,7 +518,7 @@ depending on the checkpoint frequency.</li>
 <li>Failed or latent KinesisReceivers will be detected and automatically shutdown/load-balanced by the KCL.</li>
 <li>If possible, explicitly shutdown the worker if a failure occurs.</li>
 
-Example KinesisWordCount (and JavaKiensisWordCount) notes:
+Example KinesisWordCount (and JavaKinesisWordCount) notes:
 <li>These examples automatically determine the number of threads to run locally based on the number of shards for the stream.</li>
 <li>These examples automatically determine the number of KinesisReceivers/InputDStreams to create based on the number of shards for the stream.</li>
 <li>These examples use InitialPositionInStream.LATEST (tip of stream) vs. InitialPositionInStream.TRIM_HORIZON (back 24 hours) to simplify reasoning about the examples.</li>

extras/spark-kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisRecordProcessor.scala

@@ -36,8 +36,7 @@ import org.apache.spark.streaming.util.Clock
  *
  * @param Kinesis receiver
  * @param workerId for logging purposes
- * @param checkpoint utils
- * @param Kinesis checkpoint interval (millis)
+ * @param checkpoint state
  */
 private[streaming] class KinesisRecordProcessor(
   receiver: KinesisReceiver,

project/SparkBuild.scala

@@ -65,7 +65,7 @@ object SparkBuild extends PomBuild {
     }
     if (Properties.envOrNone("SPARK_KINESIS_ASL").isDefined) {
       println("NOTE: SPARK_KINESIS_ASL is deprecated, please use -Pspark-kinesis-asl flag.")
-      profiles ++= Seq("spark-ganglia-lgpl")
+      profiles ++= Seq("spark-kinesis-asl")
     }
     if (Properties.envOrNone("SPARK_HIVE").isDefined) {
       println("NOTE: SPARK_HIVE is deprecated, please use -Phive flag.")