Re: Unable to write checkpoint metadata to s3 using pyflink (1.16.0)

2022-11-23 Thread Martijn Visser
Hi, Like the error mentions "The scheme is directly supported by Flink through the following plugin(s): flink-s3-fs-presto. Please ensure that each plugin resides within its own subfolder within the plugins directory." You can't add the plugins via code; you need to follow the instructions in the

Unable to write checkpoint metadata to s3 using pyflink (1.16.0)

2022-11-23 Thread Mujahid Niaz
Hi team, Hope Everyone is doing good, We have an issue regarding writing checkpoints metadata to S3 using pyflink datastream api. we are using Apache-Flink==1.16.0. We are able to sink our Stream into s3 but when it comes to writing checkpoint data. we are getting the following error. We tried a p