You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

运行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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.27 23:07:03