Hi,
yes you are right. I forgot that the interval is set by default when
enabling event time.
Also your comment about triggering the window is correct. Technically, you
don't need a record that falls into the next window, but just a watermark
that is past the window boundary.
In your case, waterm
Hi Fabian,
Thank you for your response! I think it's not necessary to do that
because i have a call to anyway:
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
which do exactly what you say. It set the watermark interval to 200ms .
I think i found the problem and it is the defau
Hi,
you are using a BoundedOutOfOrdernessTimestampExtractor to generate
watermarks.
The BoundedOutOfOrdernessTimestampExtractor is a periodic watermark
assigner and only generates watermarks if a watermark interval is
configured.
Without watermarks, the query cannot "make progress" and only comput
Hi,
I'm trying to run the following streaming program in my local flink
1.3.2 environment. The program compile and run without any errors but
the print() call doesn't display anything. Once i stop the program i
receive all aggregated data. Any ideas how to make it output regularly
or when new
