[FLINK-8992] Implement source and operator that validate exactly-once

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.5.0
• Component/s: Tests
• Assignee: Stefan Richter
• Reporter: Stefan Richter
• Created: 16/Mar/18 12:45
• Updated: 27/Apr/18 14:15
• Resolved: 27/Apr/18 14:15

Description

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.

Issue Links

• links to: GitHub Pull Request #5925