flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Magalhães <speeddra...@gmail.com>
Subject AWS Client Builder with default credentials
Date Thu, 20 Feb 2020 12:16:42 GMT
I'm using
org.apache.flink.fs.s3base.shaded.com.amazonaws.client.builder.AwsClientBuilder
to create a S3 client to copy objects and delete object inside
a TwoPhaseCommitSinkFunction.

Shouldn't be another way to set up configurations without put them
hardcoded ? Something like core-site.xml or flink-conf.yaml ?

Right now I need to have them hardcoded like this.

AmazonS3ClientBuilder.standard
      .withPathStyleAccessEnabled(true)
      .withEndpointConfiguration(
        new EndpointConfiguration("http://minio:9000", "us-east-1")
      )
      .withCredentials(
        new AWSStaticCredentialsProvider(new BasicAWSCredentials("minio",
"minio123"))
      )
      .build

Thanks

Mime
View raw message