Skip to content

Commit

Permalink
[FLINK-4500][docs] Update cassandra documentation regarding data loss
Browse files Browse the repository at this point in the history
As of FLINK-4500 the Cassandra connector will wait for pending updates to finish upon checkpoint.

This closes apache#5002.
  • Loading branch information
mcfongtw authored and zentol committed Nov 14, 2017
1 parent c5371ee commit fcbfbb9
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions docs/dev/connectors/cassandra.md
Original file line number Diff line number Diff line change
Expand Up @@ -101,8 +101,6 @@ Note that that enabling this feature will have an adverse impact on latency.
### Checkpointing and Fault Tolerance
With checkpointing enabled, Cassandra Sink guarantees at-least-once delivery of action requests to C* instance.

<p style="border-radius: 5px; padding: 5px" class="bg-danger"><b>Note</b>: However, current Cassandra Sink implementation does not flush the pending mutations before the checkpoint was triggered. Thus, some in-flight mutations might not be replayed when the job recovered. </p>

More details on [checkpoints docs]({{ site.baseurl }}/dev/stream/state/checkpointing.html) and [fault tolerance guarantee docs]({{ site.baseurl }}/dev/connectors/guarantees.html)

## Examples
Expand Down

0 comments on commit fcbfbb9

Please sign in to comment.