: Wednesday, June 9, 2021 at 8:34 AM
To: Joseph Lorenzini
Cc: "user@flink.apache.org"
Subject: Re: Records Are Never Emitted in a Tumbling Event Window When Each Key Only Has One Record
Hi Joe,
could you please check (in web UI) if the watermark is advancing past the
> second event has timestamp that exceeds the max timestamp of the previous
> window.
>
>
>
> Does that sound right?
>
>
>
> Thanks,
>
> Joe
>
>
>
> *From: *Arvid Heise
> *Date: *Wednesday, June 9, 2021 at 8:34 AM
> *To: *Joseph Lorenzini
> *Cc: *
records between two soruces have the exact same time, cause the watermarks to not advance?
Joe
From: Arvid Heise
Date: Wednesday, June 9, 2021 at 8:34 AM
To: Joseph Lorenzini
Cc: "user@flink.apache.org"
Subject: Re: Records Are Never Emitted in a Tumbling Event Window Whe
Hi Joe,
could you please check (in web UI) if the watermark is advancing past the
join? The window operator would not trigger if it doesn't advance.
On which Flink version are you running?
On Tue, Jun 8, 2021 at 10:13 PM Joseph Lorenzini
wrote:
> Hi all,
>
>
>
> I have observed behavior joinin
Hi all,
I have observed behavior joining two keyed streams together, where events are never emitted. The source of each stream is a different kafka topic. I am curious to know if this expected and if there’s a way
to work around it.
I am using a tumbling event window. All record
