talatuyarer commented on PR #29793:
URL: https://github.com/apache/beam/pull/29793#issuecomment-2152996624

   @je-ik Because Metrics are creating when Flink's open function but because 
they are not getting update at advance time. Flink does not receive updated 
metrics. My code change make metrics update part of checkpointing time. We are 
using this fix with 30K+ Flink jobs and build a autoscaling for Beam. 
https://beam.apache.org/blog/apache-beam-flink-and-kubernetes-part3/


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to