[Feature] Add SinkV2 implementation for Paimon Flink Sink.
- Dominant language
- Java
- Stars
- 3.4k
- Forks
- 1.4k
- Avg merge
- 1d 11h
- Merged PRs (30d)
- 396
Description
### Search before asking
- [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar.
### Motivation
I propose to add [SinkV2](https://nightlies.apache.org/flink/flink-docs-release-2.0/docs/dev/datastream/sinks/) implementation for Paimon Flink Sink.
With this new implementation, we can follow up on the optimizations made by Flink on Sink, and have a more reliable way of connecting with other ecosystem projects such as FlinkCDC or Seatunnel.
### Solution
_No response_
### Anything else?
_No response_
### Are you willing to submit a PR?
- [x] I'm willing to submit a PR!
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by reading the linked Flink SinkV2 documentation and inspecting the existing Paimon Flink Sink implementation. Define the required SinkV2 integration and its compatibility with FlinkCDC or Seatunnel; done means a working implementation with appropriate validation in the repository.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- data-engineering, stream-processing
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 30/100