Hi Folani, I see one option that we can achieve this through metrics[1]. Each operator can report it's processing time as a metric. These metrics can be gathered and queried later. For example, you can get a metric for a specified TaskManager or get max/min/avg value of all TaskManagers.
Best, Hequn [1] https://ci.apache.org/projects/flink/flink-docs-master/monitoring/metrics.html On Mon, Oct 15, 2018 at 10:26 PM Folani <[email protected]> wrote: > I'm going to work on effect of parallelism for different operators on > heterogeneous machines. > I need to know the processing time of each operator instance as well as > overall processing time of all instances of each specific operator. > I think there are different ways for this purpose. > However, what is the best way to getting these times as precise as > possible? > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
