[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15467660#comment-15467660 ]
Ivan Mushketyk commented on FLINK-3427: --------------------------------------- Hey [~rmetzger], my idea was to record a timestamp of the latest watermark on every vertex and display timestamps in the "Subtask" panel with other metrics (here is a panel I am talking about: https://cloud.githubusercontent.com/assets/592286/18147690/c287947e-6fcd-11e6-8968-ff47283635b7.png). On the other hand, we could enhance the graph representation and display watermarks and number of events for every vertex there. Maybe something similar to Google Dataflow UI: https://youtu.be/TnLiEWglqHk?t=22m4s > Add watermark monitoring to JobManager web frontend > --------------------------------------------------- > > Key: FLINK-3427 > URL: https://issues.apache.org/jira/browse/FLINK-3427 > Project: Flink > Issue Type: Improvement > Components: Streaming, Webfrontend > Reporter: Robert Metzger > Assignee: Ivan Mushketyk > > Currently, its quite hard to figure out issues with the watermarks. > I think we can improve the situation by reporting the following information > through the metrics system: > - Report the current low watermark for each operator (this way, you can see > if one operator is preventing the watermarks to rise) > - Report the number of events arrived after the low watermark (users can see > how accurate the watermarks are) -- This message was sent by Atlassian JIRA (v6.3.4#6332)