Skip to content

[core] Fix dynamic bucket allocation across partitions - #9193

Merged
JingsongLi merged 1 commit into
apache:masterfrom
ArnavBalyan:arnavb/flink-dyn-partitions
Aug 13, 2026
Merged

[core] Fix dynamic bucket allocation across partitions#9193
JingsongLi merged 1 commit into
apache:masterfrom
ArnavBalyan:arnavb/flink-dyn-partitions

Conversation

@ArnavBalyan

Copy link
Copy Markdown
Member

Purpose

  • Dynamic bucket assigners track the maximum bucket ID across all partitions.
  • Once one partition reaches dynamic-bucket.max-buckets, new partitions incorrectly - cannot create their remaining buckets and send all rows to the first available bucket. (this is incorrect and causes skew)
  • Track bucket upper bound for each partition so every partition can independently allocate its available buckets instead of having a global counter.

Tests

  • UT

@JingsongLi

Copy link
Copy Markdown
Contributor

+1

@JingsongLi
JingsongLi merged commit 17e9ad3 into apache:master Aug 13, 2026
12 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants