注意 PyFlink需要特定的Python版本(3.5, 3.6, 3.7 或 3.8)。请运行以下命令,以确保Python版本满足要求。
你的系统也许安装了好几个版本的Python。你可以运行下面的ls
命令来查看你系统中安装的Python版本有哪些:
为了满足Python版本要求,你可以选择通过软链接的方式将python
指向python3
解释器:
除了软链接的方式,你也可以选择创建一个Python virtual env(venv
)的方式。关于如何创建一个virtual env,你可以参考准备Python虚拟环境
如果你不想使用软链接的方式改变系统python
解释器的指向的话,你可以使用配置的方式指定Python解释器。
关于指定编译作业使用的Python解释器,你可以参考python client executable
关于指定执行python udf worker使用Python解释器,你可以参考python executable
PyFlink已经被发布到PyPi,可以通过如下方式安装PyFlink:
您也可以从源码手动构建PyFlink,具体可以参见开发指南.
注意 从Flink 1.11版本开始, PyFlink作业支持在Windows系统上运行,因此您也可以在Windows上开发和调试PyFlink作业了。