Skip to content

Pull requests: apache/fluss

New pull request New
287 Open 1,714 Closed
287 Open 1,714 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[server] Fix spurious ISR shrink after leader election
#3702 opened Jul 20, 2026 by fxbing Contributor Loading…
1
Added documentation for Resource protection
#3701 opened Jul 20, 2026 by MaheshS08 Contributor Loading…
1
1
[tiering] Reduce LakeSnapshot log verbosity in TieringSplitGenerator
#3700 opened Jul 20, 2026 by beryllw Contributor Loading…
[filesystem] Align Hadoop dependencies to 3.4.3
#3699 opened Jul 20, 2026 by litiliu Contributor • Draft
1 task done
1
[rust][tests] Fix flaky test_poll_batches by using retry loop for projection test
#3694 opened Jul 19, 2026 by LiebingYu Contributor Loading…
1
1
[CI] Extract flink-backward stage from lake to avoid 60min timeout
#3692 opened Jul 19, 2026 by Guosmilesmile Contributor Loading…
2
[spark] Extend get_cluster_configs procedure output with default value, is_default and description columns
#3690 opened Jul 18, 2026 by XuQianJin-Stars Contributor Loading…
[spark] Add input argument validation with friendly errors to CALL procedure framework
#3689 opened Jul 18, 2026 by XuQianJin-Stars Contributor Loading…
[common][helm] helm support for config providers
#3685 opened Jul 17, 2026 by fresh-borzoni Member Loading…
1
1
[tiering] Use fixed-delay restart strategy for Flink tiering job
#3683 opened Jul 17, 2026 by Shawn-Hx Loading…
1
4
[flink] Flink batch read based on SST merge.
#3677 opened Jul 17, 2026 by loserwang1024 Contributor Loading…
1
[flink] Support custom lookup shuffle by bucket for Flink 2.x
#3675 opened Jul 17, 2026 by naivedogger Contributor Loading…
1
3
[doc] documentation for gravitino integration
#3669 opened Jul 16, 2026 by VladBanar Contributor Loading…
1
1
[rust] Add into_stream() to bounded readers
#3664 opened Jul 16, 2026 by fresh-borzoni Member Loading…
1
1
chore: bump serde_with from 3.18.0 to 3.21.0 in /fluss-rust dependencies Pull requests that update a dependency file rust Pull requests that update rust code
#3663 opened Jul 15, 2026 by dependabot Bot Loading…
[lake] Carry opaque table-level tiering state in lake offsets file and RPC
#3660 opened Jul 15, 2026 by beryllw Contributor Loading…
1
8
[rust] Hash-distribute log-table appends by declared bucket key
#3643 opened Jul 14, 2026 by fresh-borzoni Member Loading…
1
4
[flink] Fix TableNotExistException when listing partitions on changelog / binlog virtual tables
#3641 opened Jul 13, 2026 by naivedogger Contributor Loading…
1
[lake] Support partition mark-done for lakehouse tiering (processing-…
#3635 opened Jul 11, 2026 by beryllw Contributor • Draft
1
[lookup] Support historical partition lookup for lake tables
#3630 opened Jul 10, 2026 by luoyuxia Contributor Loading…
1
38
[common] Fix equals/hashCode contract violation in Schema.PrimaryKey
#3629 opened Jul 10, 2026 by NestDream Loading…
1 of 2 tasks
1
[docs] Fix misaligned rowspans in Table/Bucket metrics table
#3624 opened Jul 8, 2026 by orangeCatDeveloper Contributor Loading…
[server] local segment ttl
#3623 opened Jul 8, 2026 by gyang94 Contributor Loading…
18
[server] Add in-memory rebalance round limit
#3622 opened Jul 8, 2026 by fhan688 Contributor Loading…
8
[kv] Add row TTL support
#3621 opened Jul 8, 2026 by platinumhamburg Contributor Loading…
1
7
ProTip! Adding no:label will show everything without a label.