Hi,各位大佬,     想请教一下,我使用flink run -m yarn-cluster -p 4 -py 
myjob.py,报错java.lang.RuntimeException: Found 0 flink-python jar.
 at 
org.apache.flink.client.program.PackagedProgram.getJobJarAndDependencies(PackagedProgram.java:263)
 at 
org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:140)
 at 
org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:68)
 at 
org.apache.flink.client.program.PackagedProgram$Builder.build(PackagedProgram.java:590)
 at org.apache.flink.client.cli.CliFrontend.buildProgram(CliFrontend.java:758)
 at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:250)
 at 
org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:968)
 at 
org.apache.flink.client.cli.CliFrontend.lambda$main$12(CliFrontend.java:1042)
 at java.security.AccessController.doPrivileged(Native Method)
 at javax.security.auth.Subject.doAs(Subject.java:422)
 at 
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1876)
 at 
org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
 at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1042)

没有发现flink-python 
jar,这个jar在哪里可以找见,site-packages/pyflink里面,还是自己构建,目前本机已经安装pyflink 1.11.1

回复