Hi Fabian,
thanks for your very goog explanation. However, I don't exactly know how to increase the watermark by myself. Do you have an example for me? Do I have to override the getCurrentWatermark method?
Thanks,
Markus
Gesendet: Dienstag, 28. Februar 2017 um 20:36 Uhr
Von: &q
Hi Fabian,
yeah, that's basically it. The events window gets closed only when a
newer event arrives (after 10 seconds window).
Can I tell Flink to close the event window at timeWindow.getEnd() even
if no newer event arrives?
Thanks,
Markus
Am 28.02.17 um 17:19 schrieb Fabian Hueske
empty "heartbeats" for the application event
stream.
Thanks for your help.
Greetings
Markus
Hi Fabian,
at first, sorry for the late answer. The given execution plan was created
after 20 minutes, only one vertex centric iteration is missing. I can
optimize the program because some operators are only needed to create
intermediate debug results, still, it's not enough to run as one Flink j
be still
interested in opinions and ideas, thanks in advance!
Best,
Markus
complexExecPlan.json
<http://apache-flink-user-mailing-li
