Python versions prior to 3.5 are not supported for pyFlink

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

Python versions prior to 3.5 are not supported for pyFlink 

Command-Line Interface | Apache Flink

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

还是报同样的错

添加

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

执行:

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

问题解决。

 以上记录我解决的过程。