We are using Flink version 1.13.0 on Kubernetes.
For checkpointing we have configured fs.s3 flink-s3-fs-presto.
We have enabled sse on our buckets with kms cmk.

flink-conf.yaml is configured as below.
s3.entropy.key: _entropy_
s3.entropy.length: 4
s3.path.style.access: true
s3.ssl.enabled: true
s3.sse.enabled: true
s3.sse.type: KMS
s3.sse.kms-key-id: <ARN of keyid>
s3.iam-role: <IAM role with read/write access to bucket>
s3.endpoint: <bucketname>.s3-us-west-2.amazonaws.com
s3.credentials-provider:
com.amazonaws.auth.profile.ProfileCredentialsProvider

However, PUT operations on the bucket are resulting in access denied error.
Access policies for the role are checked and works fine when checked with
CLI.
Also, can't get to see debug logs from presto s3 lib, is there a way to
enable logger for presto airlift logging?

Any inputs on above issue?

Reply via email to