File tree Expand file tree Collapse file tree 3 files changed +1
-6
lines changed Expand file tree Collapse file tree 3 files changed +1
-6
lines changed Original file line number Diff line number Diff line change 59
59
<artifactId >amazon-kinesis-client</artifactId >
60
60
<version >${aws.kinesis.client.version} </version >
61
61
</dependency >
62
- <dependency >
63
- <groupId >com.amazonaws</groupId >
64
- <artifactId >aws-java-sdk</artifactId >
65
- <version >${aws.java.sdk.version} </version >
66
- </dependency >
67
62
<dependency >
68
63
<groupId >org.mockito</groupId >
69
64
<artifactId >mockito-core</artifactId >
Original file line number Diff line number Diff line change @@ -178,6 +178,7 @@ private[kinesis] class KinesisReceiver(
178
178
workerThread.setName(s " Kinesis Receiver ${streamId}" )
179
179
workerThread.setDaemon(true )
180
180
workerThread.start()
181
+
181
182
logInfo(s " Started receiver with workerId $workerId" )
182
183
}
183
184
Original file line number Diff line number Diff line change 151
151
<avro .version>1.7.7</avro .version>
152
152
<avro .mapred.classifier>hadoop2</avro .mapred.classifier>
153
153
<jets3t .version>0.7.1</jets3t .version>
154
- <aws .java.sdk.version>1.9.16</aws .java.sdk.version>
155
154
<aws .kinesis.client.version>1.3.0</aws .kinesis.client.version>
156
155
<!-- org.apache.httpcomponents/httpclient-->
157
156
<commons .httpclient.version>4.3.2</commons .httpclient.version>
You can’t perform that action at this time.
0 commit comments