运行PyFlink word_count.py示例时出现执行错误求助
问题根源
错误栈最底层的Cannot run program "python": error=2, No such file or directory是核心问题——M2 MacBook Air默认仅提供python3命令,而PyFlink默认尝试调用python命令来启动Python执行环境,导致找不到可执行文件。
前面的No module named google.cloud.bigquery_storage_v1只是警告,不影响WordCount示例运行,仅当你需要使用ReadFromBigQuery的DIRECT_READ方法时才需要处理。
解决方案
方法1:创建python到python3的软链接
在终端执行以下命令(需要管理员权限时加sudo):
sudo ln -s /usr/bin/python3 /usr/local/bin/python
执行后,系统中就会有python命令指向你的Python 3.9.6,PyFlink就能正常调用了。
方法2:通过环境变量指定Python解释器
运行WordCount示例前,先设置PYFLINK_PYTHON环境变量指向你的Python 3路径:
export PYFLINK_PYTHON=/usr/bin/python3 python3 examples/python/datastream/word_count.py
或者直接在一行命令中设置:
PYFLINK_PYTHON=/usr/bin/python3 python3 examples/python/datastream/word_count.py
(可选)处理BigQuery警告
如果之后需要使用BigQuery的DIRECT_READ方法,安装对应的依赖包:
pip install google-cloud-bigquery-storage
内容的提问来源于stack exchange,提问作者Saran12
相关产品推荐
相关产品推荐

