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/
