Re: Regarding Changes in Flink Operator 1.3.1

Please see the release announcements: https://flink.apache.org/news/2022/10/07/release-kubernetes-operator-1.2.0.html https://flink.apache.org/news/2022/12/14/release-kubernetes-operator-1.3.0.html https://flink.apache.org/news/2023/01/10/release-kubernetes-operator-1.3.1.html https://nightlies.ap

Re: Regarding Changes in Flink Operator 1.3.1

also are the changes in operator version 1.3.1 backward compatible ? On Thu, Jan 19, 2023 at 12:38 PM Sumit Aich wrote: > Hi Team, > > Can you please share what has changed in Flink Kubernetes Operator version > 1.3.1 from the 1.1.0 version. > > Thanks, > Sumit >

Regarding Changes in Flink Operator 1.3.1

Hi Team, Can you please share what has changed in Flink Kubernetes Operator version 1.3.1 from the 1.1.0 version. Thanks, Sumit

Fwd: Flink Jobmanager not able to access AWS S3 for checkpoints

Hi, We are trying to deploy our Flink application (already running on AWS EMR successfully) in Kubernetes in native mode. The base image used to bake the Flink container image is flink:1.13.1-java8. For S3 access required to save checkpoints - we have placed the jar "flink-s3-fs-presto-1.13.1.jar"

Unequal distribtion of Kafka partitions with respect to topic when reading from multiple topics using KafkaSource API with Flink 1.14.3

Hi, I am using KafkaSource API read from 6 topics within Kafka. Flink version - 1.14.3. Each and every kafka topic my Flink pipeline reads from is having a different load but same number of partitions (lets say 30). For example partition 0 of topic 1 and partition 0 of topic 2 have different