* Fixed release version in build.sbt

* Fixed setupScript and lambda in Cloudformation template to reflect release 0.2
* installing sbt on master node using SBT's yum repository.

Author: shenavaa

CloudFormation/setupStep.sh

@@ -4,15 +4,17 @@ STREAMNAME=$2
 REGION=`curl --silent http://169.254.169.254/latest/dynamic/instance-identity/document | jq -r .region`
 ISMASTER=`cat /emr/instance-controller/lib/info/instance.json | jq .isMaster`
 if [ "$ISMASTER"=="true" ]; then 
- sudo yum -y install git
+ curl -L https://www.scala-sbt.org/sbt-rpm.repo > sbt-rpm.repo
+ sudo mv sbt-rpm.repo /etc/yum.repos.d/
+ sudo yum -y install sbt git
  CP="/home/hadoop"
  SNH="$CP/streaming-example/"
  BASE="$CP/aws-cloudwatch-metrics-custom-spark-listener"
  git clone "https://github.com/awslabs/aws-cloudwatch-metrics-custom-spark-listener.git" $BASE
  mkdir $SNH
  BASE="$CP/aws-cloudwatch-metrics-custom-spark-listener"
  CFLOC="$BASE/CloudFormation"
- wget "https://github.com/awslabs/aws-cloudwatch-metrics-custom-spark-listener/releases/download/beta-0.1/sparkkinesisexample_2.11-1.0.jar" -O $SNH/sparkkinesisexample_2.11-1.0.jar
+ wget "https://github.com/awslabs/aws-cloudwatch-metrics-custom-spark-listener/releases/download/beta-0.2/sparkkinesisexample_2.12-0.2.jar" -O $SNH/sparkkinesisexample_2.12-0.2.jar
  cp $BASE/CloudFormation/*.sh $SNH
  chmod 755 $SNH/*.sh
 fi

CloudFormation/streamingStep.sh

@@ -4,5 +4,5 @@ APPNAME=$1
 STREAMNAME=$2
 
 REGION=`curl --silent http://169.254.169.254/latest/dynamic/instance-identity/document | jq -r .region`
-spark-submit --packages org.apache.spark:spark-streaming-kinesis-asl_2.12:3.1.1 --class com.amazonaws.awslabs.sparkstreaming.SparkKinesisExample /home/hadoop/streaming-example/sparkkinesisexample_2.11-1.0.jar $APPNAME $STREAMNAME $REGION
+spark-submit --packages org.apache.spark:spark-streaming-kinesis-asl_2.12:3.1.1 --class com.amazonaws.awslabs.sparkstreaming.SparkKinesisExample /home/hadoop/streaming-example/sparkkinesisexample_2.12-0.2.jar $APPNAME $STREAMNAME $REGION
 

build.sbt

@@ -2,7 +2,7 @@
 // SPDX-License-Identifier: MIT-0
 
 name := "SparkKinesisExample"
-version := "1.1"
+version := "0.2"
 scalaVersion := "2.12.10"
 libraryDependencies += "org.apache.spark" % "spark-streaming_2.12" % "3.1.1"
 libraryDependencies += "com.amazonaws" % "aws-java-sdk" % "1.11.977"