From e6d13baa2544c1ac0504199f685b12872451d0e1 Mon Sep 17 00:00:00 2001 From: Michael Fong Date: Mon, 13 Nov 2017 10:17:02 +0800 Subject: [PATCH] [hotfix][docs] Remove the caveat about Cassandra connector. As FLINK-4500 being committed, Cassandra connector would now flush pending mutations properly when a checkpoint was triggered. --- docs/dev/connectors/cassandra.md | 2 -- 1 file changed, 2 deletions(-) diff --git a/docs/dev/connectors/cassandra.md b/docs/dev/connectors/cassandra.md index dd8a775278688..64d81b5c96752 100644 --- a/docs/dev/connectors/cassandra.md +++ b/docs/dev/connectors/cassandra.md @@ -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. -

Note: 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.

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