如何统计数据处理延迟Delay情况

[陈赋赟]

HI ALL
  目前想对Flink Job添加一个统计数据处理延迟情况的Metric，目前的想法是拿到数据携带的时间(Event 
Time)于当前节点的时间(System.getCurrentTime)相减，得出的值即数据延迟处理的时间，但不确定这个想法是否正确且可行，求各位大佬提供思路和想法～