diff --git a/extras/kinesis-asl/pom.xml b/extras/kinesis-asl/pom.xml index 0b1421b778529..24d4264c6759f 100644 --- a/extras/kinesis-asl/pom.xml +++ b/extras/kinesis-asl/pom.xml @@ -59,11 +59,6 @@ amazon-kinesis-client ${aws.kinesis.client.version} - - com.amazonaws - aws-java-sdk - ${aws.java.sdk.version} - org.mockito mockito-core 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 22324e821ce94..1282dafb526b1 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 @@ -178,6 +178,7 @@ private[kinesis] class KinesisReceiver( workerThread.setName(s"Kinesis Receiver ${streamId}") workerThread.setDaemon(true) workerThread.start() + logInfo(s"Started receiver with workerId $workerId") } diff --git a/pom.xml b/pom.xml index 3c745c2e8feb5..627886f640e49 100644 --- a/pom.xml +++ b/pom.xml @@ -151,7 +151,6 @@ 1.7.7 hadoop2 0.7.1 - 1.9.16 1.3.0 4.3.2