[
https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15148442#comment-15148442
]
ASF GitHub Bot commented on FLINK-3332:
---------------------------------------
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1640#discussion_r52994814
--- Diff: docs/apis/streaming/fault_tolerance.md ---
@@ -176,6 +176,11 @@ state updates) of Flink coupled with bundled sinks:
<td></td>
</tr>
<tr>
+ <td>Cassandra sink</td>
+ <td>exactly once</td>
--- End diff --
I would try to summarize the guarantees here. Or maybe add an asterisk to
the "exactly once", stating that Cassandra has no support for large atomic
inserts, but as long as cassandra is not failing, Flink failures will not cause
duplicates.
> Provide an exactly-once Cassandra connector
> -------------------------------------------
>
> Key: FLINK-3332
> URL: https://issues.apache.org/jira/browse/FLINK-3332
> Project: Flink
> Issue Type: Improvement
> Components: Streaming Connectors
> Reporter: Robert Metzger
> Assignee: Chesnay Schepler
>
> With FLINK-3311, we are adding a Cassandra connector to Flink.
> It would be good to also provide an "exactly-once" C* connector.
> I would like to first discuss how we are going to implement this in Flink.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
