Hi, 看报错是你的客户端环境所使用的的`python`解释器没有安装pyflink。-pyexec指定的是你udf运行的worker所使用的python环境，但是你在客户端编译作业的时候也需要python环境，那个python环境也需要安装pyflink。
Best, Xingbo 陈康 <[email protected]> 于2021年1月25日周一 下午9:01写道： > 你好、请教下配置pyflink、本地运行报错 > [root@hadoop01 ~]# pip list | grep flink > apache-flink (1.12.0) > > [root@hadoop01 ~]# python3 -V > Python 3.6.5 > > flink run -m localhost:8081 -py datastream_tutorial.py -pyexec > /usr/local/python3/bin/python3 > > File "datastream_tutorial.py", line 1, in <module> > from pyflink.common.serialization import SimpleStringEncoder > ModuleNotFoundError: No module named 'pyflink.common.serialization' > ，请问下你是如何配置环境变量的吗？谢谢 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
