Re: python udf 提交到本地节点执行报错

Mon, 25 Jan 2021 05:01:19 -0800 

你好、请教下配置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/

回复