@@ -8,11 +8,7 @@ import org.apache.hadoop.dynamodb.write.DynamoDBOutputFormat
88import org .apache .hadoop .dynamodb .{ DynamoDBConstants , DynamoDbClientBuilderTransformer }
99import org .apache .hadoop .mapred .JobConf
1010import org .apache .log4j .LogManager
11- import software .amazon .awssdk .auth .credentials .{
12- AwsCredentials ,
13- AwsCredentialsProvider ,
14- ProfileCredentialsProvider
15- }
11+ import software .amazon .awssdk .auth .credentials .AwsCredentialsProvider
1612import software .amazon .awssdk .services .dynamodb .{ DynamoDbClient , DynamoDbClientBuilder }
1713import software .amazon .awssdk .services .dynamodb .model .{
1814 BillingMode ,
@@ -243,9 +239,6 @@ object DynamoUtils {
243239 DynamoDBConstants .CUSTOM_CLIENT_BUILDER_TRANSFORMER ,
244240 classOf [AlternatorLoadBalancingEnabler ].getName)
245241
246- jobConf.set(
247- DynamoDBConstants .CUSTOM_CREDENTIALS_PROVIDER_CONF ,
248- classOf [ProfileCredentialsProvider ].getName)
249242 jobConf.set(" mapred.output.format.class" , classOf [DynamoDBOutputFormat ].getName)
250243 jobConf.set(" mapred.input.format.class" , classOf [DynamoDBInputFormat ].getName)
251244 }
@@ -278,13 +271,6 @@ object DynamoUtils {
278271 DynamoDBConstants .DEFAULT_CAPACITY_FOR_ON_DEMAND
279272 }
280273
281- /** Reflection-friendly credentials provider used by the EMR DynamoDB connector */
282- class ProfileCredentialsProvider
283- extends software.amazon.awssdk.auth.credentials.AwsCredentialsProvider {
284- private lazy val delegate = ProfileCredentialsProvider .create()
285- def resolveCredentials (): AwsCredentials = delegate.resolveCredentials()
286- }
287-
288274 class AlternatorLoadBalancingEnabler extends DynamoDbClientBuilderTransformer with Configurable {
289275 private var conf : Configuration = null
290276
0 commit comments