[
https://issues.apache.org/jira/browse/FLINK-15202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17449721#comment-17449721
]
Shen Zhu commented on FLINK-15202:
----------------------------------
Hey [~klion26] , I'm interested in working on this ticket, would you mind
assigning it to me?
By the way, what names do you think we should use for interval join late
events, something like *numLateRecordsDropped1* and ** *numLateRecordsDropped2?*
> Increment metric when Interval Join record is late
> --------------------------------------------------
>
> Key: FLINK-15202
> URL: https://issues.apache.org/jira/browse/FLINK-15202
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream
> Reporter: Chris Gillespie
> Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor
>
> Currently an interval join will silently drop late records. I think it would
> be quite useful to have the metric *numLateRecordsDropped* incremented when
> this happens. Window Join already does this, so it would make sense to have
> it happen for both types of joins.
> Mailing List Idea:
> [https://lists.apache.org/thread.html/f463d81db3777a529d1764723189a57c33d601a6c142441fb5036ff9%40%3Cuser.flink.apache.org%3E]
> Window Join:
>
> [https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java#L424]
> Interval Join:
> [https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java#L222]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
