Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Feature] Use new sink api for Flink connector #132

Open
1 of 2 tasks
ChaomingZhangCN opened this issue Dec 6, 2024 · 1 comment · May be fixed by #205
Open
1 of 2 tasks

[Feature] Use new sink api for Flink connector #132

ChaomingZhangCN opened this issue Dec 6, 2024 · 1 comment · May be fixed by #205
Assignees
@michaelkoepf
Labels
feature New feature or request

Comments

@ChaomingZhangCN
Copy link
Contributor

ChaomingZhangCN commented Dec 6, 2024 •
edited
Loading

Search before asking

  • I searched in the issues and found nothing similar.

Motivation

Now, fluss sink connector is based on SinkFunction, which is marked Deprecated. Use new sink api for data writing.

Solution

No response

Anything else?

No response

Willingness to contribute

  • I'm willing to submit a PR!
@ChaomingZhangCN ChaomingZhangCN added the feature New feature or request label Dec 6, 2024
michaelkoepf added a commit to michaelkoepf/fluss that referenced this issue Dec 16, 2024
@michaelkoepf
[flink] Upgraded sink connector to new API version
41e592e 
- Upgraded sink connector from deprecated RichSinkFunction to new Sink interface
- Adapted corresponding unit test cases

Issue alibaba#132
@michaelkoepf michaelkoepf linked a pull request Dec 17, 2024 that will close this issue
Open
@michaelkoepf
Copy link
Contributor

I gave this one a try, see #205. Feedback is highly appreciated.

@wuchong wuchong changed the title [Feature] Use new sink api [Feature] Use new sink api for Flink connector Dec 17, 2024
michaelkoepf added a commit to michaelkoepf/fluss that referenced this issue Dec 20, 2024
@michaelkoepf
[flink] Upgraded sink connector to new API version
6ea1b85 
- Adapted access modifiers
- Consistent naming

Issue alibaba#132
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@michaelkoepf michaelkoepf

Labels
feature New feature or request
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

[flink] Upgrade sink connector to new API version michaelkoepf/fluss
2 participants
@michaelkoepf @ChaomingZhangCN