Nico Kruber created FLINK-16556:
-----------------------------------
Summary: TopSpeedWindowing should implement checkpointing for its
source
Key: FLINK-16556
URL: https://issues.apache.org/jira/browse/FLINK-16556
Project: Flink
Issue Type: Bug
Components: Examples
Affects Versions: 1.10.0
Reporter: Nico Kruber
{\{org.apache.flink.streaming.examples.windowing.TopSpeedWindowing.CarSource}}
does not implement checkpointing of its state, namely the current speeds and
distances per car. The main problem with this is that the window trigger only
fires if the new distance has increased by at least 50 but after restore, it
will be reset to 0 and could thus not produce output for a while.
Either the distance calculation could use {{Math.abs}} or the source needs
proper checkpointing. Optionally with allowing the number of cars to
increase/decrease.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
