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

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

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