Stefan Richter created FLINK-8992:
-------------------------------------
Summary: Implement source and operator that validate exactly-once
Key: FLINK-8992
URL: https://issues.apache.org/jira/browse/FLINK-8992
Project: Flink
Issue Type: Sub-task
Components: Tests
Affects Versions: 1.5.0
Reporter: Stefan Richter
Assignee: Stefan Richter
We can build this with sources that emit sequences per key and a stateful
(keyed) operator that validate for the update of each key that the new value is
the old value + 1. This can help to easily detect if events/state were lost or
duplicates.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
