flink 1.11.0的话，依赖的beam版本是2.19.0，所以先不要用最新的beam 2.23.0
针对你这个问题，应该是在启动过程中，由于某种原因，Python进程启动失败了，常见的原因有：依赖缺失，Python版本不对等等。 按说在log文件里（你发的log信息所在的log文件），应该能看到详细的原因，你的log文件里面没有详细的失败原因吗？ > 在 2020年8月7日，下午1:44，lgs <9925...@qq.com> 写道： > > Hi Jincheng, > > 我现在碰到同样的问题，udf运行的时候会打印这样的log： > 2020-08-07 03:06:45,920 INFO > org.apache.beam.runners.fnexecution.environment.ProcessEnvironmentFactory [] > - Still waiting for startup of environment > '/usr/local/lib64/python3.6/site-packages/pyflink/bin/pyflink-udf-runner.sh' > for worker id 1-1 > 然后过一阵就pyflink退出了。 > > 我是用local模式运行的。我的beam版本是2.19 安装最新的2.23也是一样的问题。 > apache-flink版本是1.11.0 > > 请问有什么办法可以排查这个错误？ > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
