Hi Rex, I think Latency Marker is what you need [1].
Best, Yun [1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/metrics.html#latency-tracking ------------------------------------------------------------------ Sender:Rex Fenley<r...@remind101.com> Date:2020/12/21 04:57:59 Recipient:user<user@flink.apache.org> Cc:Brad Davis<brad.da...@remind101.com> Theme:See lag end-to-end Hello, Is there some proxy to seeing the relative time it takes for records to make it through an entire job plan? Maybe checkpoint alignment time would be a proxy for this? Is there metrics for that or something else that would provide signal here? Thanks! -- Rex Fenley | Software Engineer - Mobile and Backend Remind.com | BLOG | FOLLOW US | LIKE US