Hi,
I didn't dig into the code yet, just wanted to ask if someone could give
me some pointers. I'm experiencing weird behavior in python SDK, when
emitting data from stateful DoFn with event-time timer set on
GlobalWindow().max_timestamp(). The data is correctly emitted, but is
probably delayed after watermark and is dropped on first GBK downstream
(assert_that in my case), the assertion then fails. When I use
FlinkRunner it seems to work as expected (the test passes).
Did anyone see something like this before?
Thanks,
Jan
