Task manager fails to start in HA mode flink 1.19.1

2025-01-22 Thread Sigalit Eliazov
Hi, I recently upgraded to *Flink 1.19.1* and am using the *Flink Kubernetes Operator 1.9* to deploy the Flink cluster. The checkpoints are defined using PersistentVolumeClaims (PVCs), and the service account is configured with the necessary permissions. However, when starting the pipeline in *HA

Object-Reuse with Table API / Flink SQL

2025-01-22 Thread Dominik.Buenzli
Dear Flink Community I’ve got into a discussion with a colleague over the use of “object-reuse”. As far as I understood it is safe to use this configuration with the Table API or Flink SQL, but only if you’re not using the HashMap StateBackend (link