Hi Ramana, The method appearing in the exception message was updated in Flink 1.15, see [1] for more details. So I believe there must be jars of version 1.15 in your environment and could you double check that?
Regards, Dian [1] https://github.com/apache/flink/commit/dd1fddb13b2d08ade580e5b3ec6b8e910974308d On Wed, Sep 7, 2022 at 1:37 PM Ramana <ramana...@gmail.com> wrote: > Hi Xingbo > > I have double checked on this, both the flink and pyflink versions that i > have are 1.14.4 on Jobmanager and task manager. > However, I still get this error. > > Thanks > Ramana > > > > On Tue, Sep 6, 2022, 14:23 Xingbo Huang <hxbks...@gmail.com> wrote: > >> Hi Raman, >> >> This problem comes from the inconsistency between your flink version and >> pyflink version >> >> Best, >> Xingbo >> >> Ramana <ramana...@gmail.com> 于2022年9月6日周二 15:08写道： >> >>> Hello there, >>> >>> I have a pyflink setup of 1 : JobManager - 1 : Task Manager. >>> >>> Trying to run a pyflink job and no matter what i do, i get the following >>> error message. >>> >>> ----------------- >>> The program finished with the following exception: >>> >>> org.apache.flink.client.program.ProgramInvocationException: The main >>> method caused an error: java.lang.NoSuchMethodError: >>> org.apache.flink.util.NetUtils.getAvailablePort()Lorg/apacheflink/util/NetUtils$Port; >>> .... >>> Caused by: java.lang.NoSuchMethodError: >>> org.apache.flink.util.NetUtils.getAvailablePort()Lorg/apacheflink/util/NetUtils$Port; >>> at >>> org.apache.flink.client.python.PythonEnvUtils.lambda$startGatewayServer$3(PythonUtils.java:365) >>> at java.lang.Thread.run(Thread.java:750) >>> ------------ >>> >>> Tried executing with some out of the box examples, yet I get the same >>> error above. >>> >>> Could anybody shed some light on why the error is occurring, and how I >>> can have it resolved? >>> >>> Appreciate any help here. >>> >>> Thanks. >>> Ramana >>> -- >>> DREAM IT, DO IT >>> >>
