flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 陈赋赟 <astion_...@163.com>
Subject 如何统计数据处理延迟Delay情况
Date Thu, 05 Sep 2019 08:25:49 GMT
HI ALL
  目前想对Flink Job添加一个统计数据处理延迟情况的Metric,目前的想法是拿到数据携带的时间(Event
Time)于当前节点的时间(System.getCurrentTime)相减,得出的值即数据延迟处理的时间,但不确定这个想法是否正确且可行,求各位大佬提供思路和想法~
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message