[FLINK-26820] Improve Cassandra connector by adding missing features and refactoring to latest standards - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Open
Priority: Major
Resolution: Unresolved
Affects Version/s: None
Fix Version/s: None
Component/s: Connectors / Cassandra
Labels:
None

Description

The current Cassandra connector in Flink has been stale in terms of contributions. As a result, it lacks certain features that are important for a proper Flink connector and needs some refactoring to be compliant with the latest Flink solutions. This ticket is an umbrella ticket to track those efforts.

Attachments

Sub-Tasks

1.	Refactor Cassandra Sink implementation to the ASync Sink	Open	Poorvank Bhatia
2.	Add Source implementation for Cassandra connector	Closed	Etienne Chauchot
3.	Make Cassandra Sink available for Flink SQL users	Open	Unassigned
4.	Make Cassandra Source available for Flink SQL users	Open	Unassigned
5.	Upgrade Flink's supported Cassandra versions to match with the Cassandra community supported versions	Closed	Etienne Chauchot
6.	Better documentation on C* sink on consistency guarantee	Open	Unassigned
7.	Possible direct memory leak in cassandra sink	Open	Unassigned
8.	Recovering from savepoint key does not exist in S3	Open	Unassigned

Activity

People

Assignee:: Unassigned

Reporter:: Martijn Visser

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 23/Mar/22 08:12

Updated:: 23/Mar/22 13:12