Re: Watermark idleness and alignment - are they exclusive?

That looks exactly like what we hit, thank you! On Thu, Jun 15, 2023 at 10:57 PM Ken Krugler wrote: > I think you’re hitting this issue: > > https://issues.apache.org/jira/browse/FLINK-31632 > > Fixed in 1.16.2, 1.171. > > — Ken > > > On Jun 15, 2023, at 1:39 PM, Piotr Domagalski > wrote: > >

Re: Watermark idleness and alignment - are they exclusive?

I think you’re hitting this issue: https://issues.apache.org/jira/browse/FLINK-31632 Fixed in 1.16.2, 1.171. — Ken > On Jun 15, 2023, at 1:39 PM, Piotr Domagalski wrote: > > Hi all! > > We've been experimenting with watermark alignment

Watermark idleness and alignment - are they exclusive?

Hi all! We've been experimenting with watermark alignment in Flink 1.15 and observed an odd behaviour that I couldn't find any mention of in the documentation. With the following strategy: WatermarkStrategy.forBoundedOutOfOrderness(Duration.ofSeconds(60)) .withTimestampAssigner((e, t) ->