[jira] [Created] (FLINK-16556) TopSpeedWindowing should implement checkpointing for its source

[Shang Yuanchun (Jira)]

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)