Re: Interval Join Late Record Metrics

63f12d436a2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java#L222> > Best, > Congxian > > > Chris Gillespie 于2019年12月11日周三 上午8:09写道： > >> Hello Flink users, first time poster here. >> >> I'm using an i

Interval Join Late Record Metrics

there a good way to monitor when an interval join fails to join two streams? Currently I'm looking at the delta between two operator metrics, but it hasn't looked that reliable so far. Thanks, Chris Gillespie