On Wed, Jun 4, 2025 at 7:40 AM Poorvank Bhatia <puravbhat...@gmail.com> wrote:
> Hi all, > Following the earlier discussion on modernizing the Cassandra Sink (initial > thread <https://lists.apache.org/thread/8v7wlx23svvwzb9568fos8lkxobcty7y > >), > FLIP-533 > < > https://cwiki.apache.org/confluence/display/FLINK/FLIP-533%3A+Cassandra+Sink+V2 > > > has now been created: > > This FLIP proposes a two-phase redesign: > > - > > *Phase 1* introduces a modular Sink V2-based Cassandra sink with async > write support, type-agnostic configuration, and better integration with > Flink's threading and checkpointing model. > - > > *Phase 2* builds on top of Flink 2.1 (FLIP-509), adding partition-aware > batching using AsyncSinkWriter, enabling efficient Cassandra writes > while avoiding cross-partition batch anti-patterns. > > Looking forward to hearing your thoughts and suggestions. > > Thanks, > > Poorvank >
