# Flink

## Sources

* [Official flink "how to install"](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/resource-providers/standalone/kubernetes)
* [An old guide](https://python.plainenglish.io/apache-beam-flink-cluster-kubernetes-python-a1965f37b7cb)

## 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
```