Hi! We're testing the flink kubernetes operator (v...
# troubleshooting
o
Hi! We're testing the flink kubernetes operator (version 1.5.0, flink version 1.17.1). We enabled the autoscaler feature but the operator cannot find any PENDING_RECORDS metrics. We're using flink-sql-connector-kafka version 1.17.1 for our sources. I can see a pendingRecords metric on the source when looking at the dashboard. Is this something I need to manually expose so the operator can pick it up?
My bad. Turns out the operator version was 1.4 which adds the pending records as a required metric. Which 1.5 avoids. Sorry! πŸ˜…
πŸ‘ 1