On Tue, May 10, 2016 at 5:36 PM, milind parikh wrote:
> When will the Cassandra sink be released? I am ready to test it out even
> now.
You can work with Chesnay's branch here:
https://github.com/apache/flink/pull/1771
Clone his repo via Git, check out the branch, and then build it from
source
Hi Chesnay
Sorry for asking the question in a confusing manner. Being new to flink,
there are many questions swirling around in my head.
Thanks for the details in your answers. Here's the facts , as I see them:
(a) Cassandra Counters are not idempotent
(b) The failures, in context of Cassandra,
Hello Milind,
I'm not entirely sure i fully understood your question, but I'll try
anyway :)
There is now way to provide exactly-once semantics for Cassandra's
counters. As such we (will) only provide exactly-once semantics for a
subset of Cassandra operations; idempotent inserts/updates.
Given FLINK 3311 & 3332, I am wondering it would be possible, without
idempotent counters in Cassandra, to deliver on an exactly once sink into
Cassandra. I do note that the verbiage/disc2 in 3332 does warn the user
that this is not exactly "exactly once" sink.
However my question has to do with
