4 questions
0
votes
0
answers
66
views
Missing required TM metrics error in flink autoscaler
I am trying to implement Flink autoscaler in the Flink Kubernetes operator. I am seeing the following error in the operator logs:
java.lang.RuntimeException: Missing required TM metrics
at org.apache....
0
votes
1
answer
128
views
Are Services automatically created for FlinkDeployments in k8s?
I have some annotations I would like to add to the (kind: Service) yaml for a FlinkDeployment but I am having trouble finding where I would add the custom annotations:
annotations:
routing.mesh.net/...
0
votes
1
answer
971
views
Flink Kubernetes Operator ok K8s - how to end pods after job is finished?
Flink Kubernetes Operator is installed according to Quick Start guide: "https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/try-flink-kubernetes-operator/quick-start/"...
- 1
1
vote
1
answer
565
views
Flink Checkpoints Stalling and Timing Out with Latency-related Errors
Recently, I've upgraded an existing Flink job (previously running Flink 1.15) to run against the official Flink Kubernetes Operator (targeting Flink 1.18) and have started to see some strange ...
- 76.9k