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