again (= added latency)
>
>
>
> Thias
>
>
>
> *From:* Alexis Sarda-Espinosa
> *Sent:* Tuesday, February 6, 2024 9:48 AM
> *To:* Schwalbe Matthias
> *Cc:* user
> *Subject:* Re: Idleness not working if watermark alignment is used
>
>
>
> ⚠*EXTERNAL MESSAGE –
Subject: Re: Idleness not working if watermark alignment is used
⚠EXTERNAL MESSAGE – CAUTION: Think Before You Click ⚠
Hi Matthias,
thanks for looking at this. Would you then say this comment in the source code
is not really valid?
https://github.com/apache/flink/blob/release-1.18/flink-runtime/src
e .idleWatermarkExcemption(…) to
> make it more obvious.
>
>
>
> Hope this helps
>
>
>
>
>
> Thias
>
>
>
>
>
>
>
> *From:* Alexis Sarda-Espinosa
> *Sent:* Monday, February 5, 2024 6:04 PM
> *To:* user
> *Subject:* Re: Idleness not working if
rather rename
.withIdleness(…) to something like .idleWatermarkExcemption(…) to make it more
obvious.
Hope this helps
Thias
From: Alexis Sarda-Espinosa
Sent: Monday, February 5, 2024 6:04 PM
To: user
Subject: Re: Idleness not working if watermark alignment is used
Ah and I forgot to mention
Ah and I forgot to mention, this is with Flink 1.18.1
Am Mo., 5. Feb. 2024 um 18:00 Uhr schrieb Alexis Sarda-Espinosa <
sarda.espin...@gmail.com>:
> Hello,
>
> I have 2 Kafka sources that are configured with a watermark strategy
> instantiated like this:
>
> WatermarkStrategy.forBoundedOutOfOrder
