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 >
