pyflink，ImportError：没有名为 pyflink 的模块

Question

我正在测试 pyflink

• 操作系统：centos7
• flink 版本：flink-1.14.3
• virtualenv python 版本：Python 3.6.8

点子列表：

• apache-beam 2.27.0
• apache-flink 1.14.3
• apache-flink-libraries 1.14.3
• avro-python3 1.9.2.1
• 证书 2021.10.8
• 字符集规范化器 2.0.11
• cloudpickle 1.2.2
• crcmod 1.7
• 莳萝 0.3.1.1
• doopt 0.6.2
• fastavro 0.23.6
• 未来 0.18.2
• grpcio 1.43.0
• hdfs 2.6.0
• httplib2 0.17.4
• idna 3.3
• 模拟 2.0.0
• numpy 1.19.5
• oauth2client 4.1.3
• 熊猫 1.1.5
• pbr 5.8.1
• 点 21.3.1
• protobuf 3.17.3
• py4j 0.10.8.1
• pyarrow 2.0.0
• pyasn1 0.4.8
• pyasn1-modules 0.2.8
• pydot 1.4.2
• pyflink 1.0
• pymongo 3.12.3
• pyparsing 3.0.7
• python-dateutil 2.8.0
• pytz 2021.3
• 请求 2.27.1
• RSA 4.8
• 设置工具 59.6.0
• 六个1.16.0
• 打字扩展 3.7.4.3
• urllib3 1.26.8
• 车轮 0.37.1

我试图运行这个命令：

• (virtualenv) [myuser@myvm flink-1.14.3] ./bin/flink run -py examples/python/table/word_count.py 并得到以下错误：

原因：java.io.IOException：执行命令失败：python -c import pyflink;import os;print(os.path.join(os.path.abspath(os.path.dirname(pyflink.文件)), 'bin')) 输出：回溯（最近一次调用最后一次）： 文件“”，第 1 行，在 ImportError: 没有名为 pyflink 的模块

我确定 pyflink 包已经安装。有谁知道为什么？

Answer 1

安装 PyFlink，只需要执行：

python -m pip install apache-flink

并确保您拥有兼容的 Python 版本 (>= 3.5)。

可能是Python虚拟环境的问题，参考https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/python/faq/#preparing-python-virtual-environment

你也可以添加选项'-pyexec venv.zip/venv/bin/python3'并试一试