Working with Flink

2025-05-22 Thread Bryan Cantos
Hello, I have deployed the Flink Operator via helm chart ( https://github.com/apache/flink-kubernetes-operator) in our kubernetes cluster. I have a use case where we want to run ephemeral jobs so I created a FlinkDeployment and am trying to submit a job via FlinkSessionJob. I have sent example yam

BackendBuildingException when trying to restore heap backend from S3 : The specified key does not exist. (Service: Amazon S3; Status Code: 404...)

2025-05-22 Thread Jean-Marc Paulin
Hi, We are running Flink 1.20.1, and see a strange issue when trying to read a savepoint from minio/S3 to a hashmap backend. At first we'd think the file is not there, but when checking the S3 bucket the file is there. This is not systematic and only happens from time to time. We think it's an env

Flink 2.0 savepoint compatibility

2025-05-22 Thread Praveen Chandna via user
Hello Savepoint created using the Flink 1.20.1 release are guaranteed to be compatible with Flink 2.0 ? Below page is from the Flink 2.0 release and it doesn't contains the compatibility matrix for Flink 2.0. https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/ops/upgrading/#compati