Re: Cdc on HA postgresql

egards > Lasse Nedergaard > > > Den 26. nov. 2024 kl. 08.13 skrev Gunnar Morling < > gunnar.morl...@googlemail.com>: > >  > Hey all, > > Postgres 17 supports failover slots, i.e. a replication slot can be > created on the primary instance and its state

Re: Cdc on HA postgresql

Hey all, Postgres 17 supports failover slots, i.e. a replication slot can be created on the primary instance and its state will be synched to corresponding slots on a stand-by server. This allows consumers to continue to read from that slot after promoting a stand-by to primary, without missing a

Re: Which base image to use for pyflink on k8s with flink operator ?

Hey, I ran into some issues with PyFlink on Kubernetes myself a while ago. Blogged about it here, perhaps it's useful: https://www.decodable.co/blog/getting-started-with-pyflink-on-kubernetes Best, --Gunnar Am Fr., 14. Juni 2024 um 20:58 Uhr schrieb Mate Czagany : > Hi, > > You can refer t

Re: Running FlinkSQL locally

Hi Ralf, Have you tried _only_ adding flink-sql-connector-kafka-1.17.1.jar to the lib directory of your Flink deployment? It is a fat JAR, with all the dependencies shaded into it, so when you add them separately again, they will clash. Best Am Mi., 11. Okt. 2023 um 04:26 Uhr schrieb Ralph Matth

Re: Upgrading pyflink to 1.16.0

Hey Ramana, I can't help you with that particular script, but perhaps this commit is helpful to you which I did for upgrading the PyFlink Playground project to 1.16: https://github.com/apache/flink-playgrounds/commit/4aa9a341bbf49e51809bc9cfcf0e946b2accd8ac In particular see the changes to