Setting up Python for PyFlink
Before you can use Flink with the Python API, you need to create and initialize a Python virtual environment.
- Connect to the Flink Gateway node using
CLI.
Provide your workload password when prompted.ssh <[***WORKLOAD USERNAME***]>@[***FLINK MANAGER NODE***] - Create a Python virtual environment using the following
command:
conda create --copy -y -n flink_venv python=3.8 - Activate the newly created virtual
environment:
conda activate flink_venv - Install PyFlink to the
flink_venvvirtual environment using the following command:python -m pip install apache-flink==1.19.1 - Create a ZIP archive from the
flink_venvvirtual environment so it can be deployed with a Flink job:cd path/to/flink_venv && zip -r venv.zip .
When the Python installation is complete, you can submit Flink application that were created using the Python API.
