[GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data...

[bowenli86]

Github user bowenli86 commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4665#discussion_r138513684
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
 ---
    @@ -132,6 +133,13 @@
         */
        protected final OutputTag<IN> lateDataOutputTag;
     
    +   /**
    +   * Metrics about the lost data due to arrive late.
    +   * */
    +   protected final String loseData = "lost_data";
    +
    +   protected Counter lostDataCount;
    --- End diff --
    
    Should this be registered on Flink metric system?


---