Hi antonio, latency is exposed via a metric. You can find each operator's latency through flink UI(Overview->Task Metrics -> select the task, for example select the sink -> Add metric -> find latency metric)
On Tue, Jun 26, 2018 at 11:18 PM, antonio saldivar <ansal...@gmail.com> wrote: > Hello thank you > > I also was trying using Flink UI Metrics on version 1.4.2 > *env.getConfig().setLatencyTrackingInterval(1000L), > *But looks like is not displaying anything > > El mar., 26 jun. 2018 a las 10:45, zhangminglei (<18717838...@163.com>) > escribió: > >> Hi, You can do that but it does not makes sense in general. But you can >> do that by flink, storm, spark streaming or structured streaming. And make >> a compare the latency under different framework. >> >> Cheers >> Minglei >> >> 在 2018年6月26日，下午9:36，antonio saldivar <ansal...@gmail.com> 写道： >> >> Hello Thank you for the feedback, >> >> Well for now I just Want to measure the time that takes form Source to >> Sink each transaction add the start and end time in mills >> >> >> >> El mar., 26 jun. 2018 a las 5:19, zhangminglei (<18717838...@163.com>) >> escribió: >> >>> Hi，Antonio >>> >>> Usually, the measurement of delay is for specific business I think it is >>> more reasonable. What I understand of latency from my experience is data >>> preparation time plus query calculation time. It is like an end to end >>> latency test. Hopes this can help you. Not point to the latency of flink >>> >>> Cheers >>> Minglei >>> >>> >>> > 在 2018年6月26日，上午5:23，antonio saldivar <ansal...@gmail.com> 写道： >>> > >>> > Hello >>> > >>> > I am trying to measure the latency of each transaction traveling >>> across the system as a DataSource I have a Kafka consumer and I would like >>> to measure the time that takes from the Source to Sink. Does any one has an >>> example?. >>> > >>> > Thank you >>> > Best Regards >>> >>> >>> >>
