Hey,
maybe your event time time-stamps are wrong, leading to an obscure year
(1705471 instead of 2020). Flink send's Long.MAX_Value as the final
watermark.
On Sat, Dec 12, 2020 at 2:29 PM Appleyuchi wrote:
>
>
> I'm trying flatAggregate, the whole code is bug free and as follows:
>
> https://pa
I'm trying flatAggregate, the whole code is bug free and as follows:
https://paste.ubuntu.com/p/TM6n2jdZfr/
the result I get is:
8>
(true,1,+1705471-09-26T16:50,+1705471-09-26T16:55,+1705471-09-26T16:54:59.999,4,1)
4>
(true,3,+1705471-09-26T16:50,+1705471-09-26T16:55,+1705471-09-26T16:54:5
