Re: Flink on Native Kubernetes S3 checkpointing error

2021-11-22 Thread Matthias Pohl
Cool, thanks for the update. Matthias On Mon, Nov 22, 2021 at 6:42 PM bat man wrote: > Hi Matthias, > > Looks like the service account token volume projection was not working > fine with the EKS version I was running. Upgraded the version and with the > same configs now the s3 checkpointing is

Re: Flink on Native Kubernetes S3 checkpointing error

2021-11-22 Thread bat man
Hi Matthias, Looks like the service account token volume projection was not working fine with the EKS version I was running. Upgraded the version and with the same configs now the s3 checkpointing is working fine. So, in short, on AWS use EKS v1.20+ for IAM Pod Identity Webhook. Thanks, Hemant O

Re: Flink on Native Kubernetes S3 checkpointing error

2021-11-22 Thread Matthias Pohl
Hi bat man, this feature seems to be tied to a certain AWS SDK version [1] which you already considered. But I checked the version used in Flink 1.13.1 for the s3 filesystem. It seems like the version that's used (1.11.788) is good enough to provide this feature (which was added in 1.11.704): ``` $

Flink on Native Kubernetes S3 checkpointing error

2021-11-21 Thread bat man
Hi, I am using flink 1.13.1 to use checkpointing(RocksDB) on s3 with native kubernetes. Passing in this parameter to job - *-Dfs.s3a.aws.credentials.provider=com.amazonaws.auth.WebIdentityTokenCredentialsProvider* I am getting this error in job-manager logs - *Caused by: com.amazonaws.AmazonClie