Kubernetes JobManager and TaskManager minimum/maximum resources

2023-01-19 Thread Lee Parayno
instances. Lee Parayno Sent from my iPhone

Apache Beam MinimalWordCount on Flink on Kubernetes using Flink Kubernetes Operator on GCP

2023-01-17 Thread Lee Parayno
I have a Kubernetes cluster in GCP running the Flink Kubernetes Operator. I'm trying to package a project with the Apache Beam MinimalWordCount using the Flink Runner as a FlinkDeployment to the Kubernetes Cluster Job Docker image created with this Dockerfile: FROM flink ENV FLINK_CLASSPATH /op