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 the PyFlink job itself, where that legacy stringly-typed API couldn't be used any longer. Best, --Gunnar Am Di., 10. Jan. 2023 um 07:46 Uhr schrieb Ramana <ramana...@gmail.com>: > > All - I am trying to upgrade my pyflink installation from 1.15.2 to 1.16.0. > Could someone tell me if that's possible via the > 'setup-pyflink-virtual-env.sh 1.16.0' command? I don't want to overwrite any > of my configuration files, so what's the clean way of upgrading to 1.16.0? > > Thanks for your help > - Ramana.