You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Lorenzo Affetti (Jira)" <ji...@apache.org> on 2024/05/15 09:05:00 UTC

[jira] [Commented] (FLINK-26821) Refactor Cassandra Sink implementation to the ASync Sink

    [ https://issues.apache.org/jira/browse/FLINK-26821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846558#comment-17846558 ] 

Lorenzo Affetti commented on FLINK-26821:
-----------------------------------------

[~mzuehlke] are you working on this?

Otherwise I would be happy to pick it up [~martijnvisser] 

> Refactor Cassandra Sink implementation to the ASync Sink
> --------------------------------------------------------
>
>                 Key: FLINK-26821
>                 URL: https://issues.apache.org/jira/browse/FLINK-26821
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Connectors / Cassandra
>            Reporter: Martijn Visser
>            Assignee: Marco Zühlke
>            Priority: Major
>
> The current Cassandra connector is using the SinkFunction. This needs to be ported to the correct Flink API, which for Cassandra is most likely the ASync Sink. More details about this API can be found in FLIP-171 https://cwiki.apache.org/confluence/display/FLINK/FLIP-171%3A+Async+Sink. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)