Re: Interval Join Late Record Metrics

Thanks Congxian, I made a JIRA to track this request. https://issues.apache.org/jira/browse/FLINK-15202 On Wed, Dec 11, 2019 at 12:56 AM Congxian Qiu wrote: > Hi Chris > > From the code[1], currently, IntervalJoin will ignore the late data > silently, maybe you can create an issue to track this.

Re: Interval Join Late Record Metrics

Hi Chris >From the code[1], currently, IntervalJoin will ignore the late data silently, maybe you can create an issue to track this. [1] https://github.com/apache/flink/blob/5c89d12849ea2aa332126b32808e363f12d436a2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/Int

Interval Join Late Record Metrics

Hello Flink users, first time poster here. I'm using an interval join in my Flink project, however I haven't found where late records get logged in metrics. Window Joins have "numLateRecordsDropped" implemented