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 >> >
