Fred Damstra (Macbook 2015)
8ec77dacc3
Flink work. Minio added.
|
пре 2 година | |
|---|---|---|
| .. | ||
| old | пре 2 година | |
| 1.flink-configuration-configmap.yaml | пре 2 година | |
| 2.jobmanager-service.yaml | пре 2 година | |
| 3.jobmanager-session-deployment-non-ha.yaml | пре 2 година | |
| 4.taskmanager-session-deployment.beam.yaml | пре 2 година | |
| 4.taskmanager-session-deployment.yaml.dist | пре 2 година | |
| 5.beam-service.yaml | пре 2 година | |
| readme.md | пре 2 година | |
| requirements.txt | пре 2 година | |
readme.md
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