Hi Jeff, I think this happens in the WatermarksWithIdleness [1].
[1] https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarksWithIdleness.java#L73 Cheers, Till On Tue, Jan 11, 2022 at 6:05 PM Jeff Carter <jpcarter...@gmail.com> wrote: > I'm looking into making a feature for flink related to watermarks and am > digging into the inner watermark mechanisms, specifically with idleness. > I'm familiar with idleness, but digging into the root code I can only get > to where idlenessTimeout gets set in WatermarkStrategyWithIdleness.java. > > But what I'm looking for the pieces beyond that. If I set the idleness to > 500 milliseconds, where in the code does it actually go "I haven't seen a > message in 500 milliseconds. I'm setting this stream to idle."? > > The reason being that what I'm thinking of would need to be able to see if > any streams are marked idle, and if so react accordingly. > > Thanks for any help in advance. >
