Maximilian Michels created FLINK-31299:
------------------------------------------
Summary: PendingRecords metric might not be available
Key: FLINK-31299
URL: https://issues.apache.org/jira/browse/FLINK-31299
Project: Flink
Issue Type: Bug
Components: Autoscaler, Kubernetes Operator
Reporter: Maximilian Michels
Assignee: Maximilian Michels
Fix For: kubernetes-operator-1.5.0
The Kafka pendingRecords metric is only initialized on receiving the first
record. For empty topics or checkpointed topics without any incoming data, the
metric won't appear.
We need to handle this case in the autoscaler and allow downscaling.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
