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] Improve the parallelism of Flink database compression commit operators #3231

Open
1 of 2 tasks
zhourui999 opened this issue Apr 18, 2024 · 0 comments
Open
1 of 2 tasks

[Feature] Improve the parallelism of Flink database compression commit operators #3231

zhourui999 opened this issue Apr 18, 2024 · 0 comments
Labels
enhancement New feature or request

Comments

@zhourui999
Copy link
Contributor

zhourui999 commented Apr 18, 2024 •
edited

Search before asking

  • I searched in the issues and found nothing similar.

Motivation

The parallelism of the commit operator in the current Flink database compression is 1, which is relatively inefficient
image
image

Solution

I think we can improve the parallelism of the commit operator by shuffling by table

Anything else?

No response

Are you willing to submit a PR?

  • I'm willing to submit a PR!
@zhourui999 zhourui999 added the enhancement New feature or request label Apr 18, 2024
@zhourui999 zhourui999 changed the title [Feature] Improve the concurrency of Flink database compression commit operators [Feature] Improve the parallelism of Flink database compression commit operators Apr 18, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
enhancement New feature or request
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@zhourui999