Installing Python for PyFlink
Before you can use Flink with the Python API, you need to install Python on your clusters if Python is not already installed on the Flink Gateway node and the YARN NameNode.
Connect to the Flink Gateway node using CLI.
Check the version of Python.
If the command fails or the versions are lower than 3.6, install Python.
Install Python using the following command:
python -m pip install apache-flink==1.16.1
- Install Python on the YARN NameNode as well using the same steps.