Flink

Sources

Process

Files have been modified:

Loadbalancer Server Added with Auth
Beam config added to 4.taskmanager-session-deployment.beam.yaml

Apply each in turn. I didn't use a separate namespace as it broke http auth.

Testing

Didn't work... hopefully I'll update these notes.

python3.10 -m venv env
source env/bin/activate
pip3 install -r requirements.txt
python3.10 test-beam.py