Strange time format output by flink

[Appleyuchi]

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,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,4,1)
4> (true,3,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,2,1)
7> (true,1,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,3,1)
8> (true,1,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,4,2)
4> (true,3,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,2,2)
7> (true,1,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,3,2)

the time format seems strange,
for example,
[phone]T16:50
what's this?

Where am I wrong in my code?
Thanks~!

 

[rmetzger0]

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 <[hidden email]> wrote:

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,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,4,1)
4> (true,3,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,2,1)
7> (true,1,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,3,1)
8> (true,1,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,4,2)
4> (true,3,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,2,2)
7> (true,1,[phone]T16:50,[phone]T16:55,[phone]T16:54:59.999,3,2)

the time format seems strange,
for example,
[phone]T16:50
what's this?

Where am I wrong in my code?
Thanks~!