Hi all, Just 3 quick questions both related to Flink metrics, especially around sinks:
1. In the Flink UI Sources always have 0 input records / bytes and Sinks always have 0 output records / bytes? Why is it like that? 2. What is the best practice for instrumenting off the shelf Flink sinks? Currently the only metrics available are num records/bytes in and out at the operator and task scope. For the task scope there are extra buffer metrics. However the output metrics are always zero (see question 1). How can one know the actual number of successful writes done by an off the shelf Flink sink? Or the latency of the write operation? 3. Is it possible to configure Flink to get global job metrics for all subtasks of an operator? Or are there any best practices around that? Thanks, M
