Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released

Hey! I am afraid the OperatorHub hasn't been updated for some time. So I am not sure when / if this will be published there. Let me link some folks who expressed interest in helping with this and hopefully we can get this release there :) Cheers, Gyula On Thu, Mar 6, 2025 at 8:17 AM Graham John

Re: Clusters restarting without checkpoints from HA metadata

We're considering avoiding point 4 above (The HA configmap containing the checkpoint reference is cleaned up) by patching our deployment of Flink to never have flink-kubernetes clean up job configmaps, by commenting out the contents of KubernetesLeaderElectionHaServices#internalCleanupJobData. Are

[ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released

Hi All! The Apache Flink community is very happy to announce the release of Apache Flink Kubernetes Operator 1.11.0. The Flink Kubernetes Operator allows users to manage their Apache Flink applications and their lifecycle through native k8s tooling like kubectl. Release blogpost: https://flink.a

Problem with the committed offsets while using KafkaSource and having the checkpointing enabled

Hi team! We have observed strange behavior when using KafkaSource and have checkpointing enabled. Even if we do not get checkpoint failures or any means of errors, we see the committed offset going up and down in a crazy manner instead of moving up to reach the end offset of that X topic. We know