You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/03/16 12:46:00 UTC
[jira] [Created] (FLINK-8992) Implement source and operator that
validate exactly-once
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)