大家好，我刚才修改了集群的flink配置文件 python.client.executable: /usr/bin/python3.6 ，将集群三台机器的Python默认 改为了python3.6
flink版本：1.11 flink on yarn集群搭建的，通过per-job模式提交任务的 提交命令：flink run -m yarn-cluster -ytm 2048 -s 2 -p 2 -py traffic.py 提交之后出现了新的问题，看报错是目录权限问题，是通过 先离线安装到cached_dir 然后提交的
