Hi,
Thanks for reporting the issue. I think this might be caused by
System.currentTimeMillis() not being monotonic [1] and the fact Flink is
accessing this function per element multiple times (at least twice: first for
creating a window, second to perform the check that has failed in your
Hi,
I have a job that uses processing time session window with inactivity gap
of 60ms where I intermittently run into the following exception. I'm trying
to figure out what happened here. Haven't been able to reproduce this
scenario. Any thoughts?
java.lang.UnsupportedOperationException: *The end
