Github user spdrnl commented on the pull request:
https://github.com/apache/flink/pull/1640#issuecomment-189210134
In some circumstances it is possible to make writes to Cassandra
idempotent, by adding an unique id to the insert. See the example below.
Counters are probably different
Github user spdrnl commented on a diff in the pull request:
https://github.com/apache/flink/pull/1620#discussion_r54090368
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericExactlyOnceSink.java
---
@@ -0,0 +1,173
