Skip to content
Closed
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import com.amazonaws.auth.AWSCredentials;
import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.auth.InstanceProfileCredentialsProvider;
import com.amazonaws.auth.EC2ContainerCredentialsProviderWrapper;
import com.amazonaws.http.IdleConnectionReaper;
import com.amazonaws.internal.StaticCredentialsProvider;
import com.amazonaws.services.s3.AmazonS3;
Expand Down Expand Up @@ -132,7 +132,7 @@ static AWSCredentialsProvider buildCredentials(Logger logger, DeprecationLogger
}
if (credentials == null) {
logger.debug("Using instance profile credentials");
return new PrivilegedInstanceProfileCredentialsProvider();
return new PrivilegedEC2ContainerCredentialsProviderWrapper();
} else {
logger.debug("Using basic key/secret credentials");
return new StaticCredentialsProvider(credentials);
Expand All @@ -157,11 +157,11 @@ protected void doClose() throws ElasticsearchException {
IdleConnectionReaper.shutdown();
}

static class PrivilegedInstanceProfileCredentialsProvider implements AWSCredentialsProvider {
private final InstanceProfileCredentialsProvider credentials;
static class PrivilegedEC2ContainerCredentialsProviderWrapper implements AWSCredentialsProvider {
private final EC2ContainerCredentialsProviderWrapper credentials;

private PrivilegedInstanceProfileCredentialsProvider() {
this.credentials = new InstanceProfileCredentialsProvider();
private PrivilegedEC2ContainerCredentialsProviderWrapper() {
this.credentials = new EC2ContainerCredentialsProviderWrapper();
}

@Override
Expand Down
Loading