Python versions prior to 3.5 are not supported for pyFlink

Python versions prior to 3.5 are not supported for pyFlink 版本：         flink1.12 命令:

./flink run --target yarn-per-job --python ***.py

报错:

Python versions prior to 3.5 are not supported for pyFlink 

根据官方文档指定pyFlink

Command-Line Interface | Apache Flink

更改命令:

./flink run --pyExecutable /opt/anaconda3/bin/python3.7 --target yarn-per-job --python ***.py

还是报同样的错

修改con/flink-conf.yaml

添加

python.client.executable: /opt/anaconda3/bin/python3.7

执行:

./flink run --target yarn-per-job --python ***.py

问题解决。

 以上记录我解决的过程。