Skip to content

Pull requests: apache/fluss

New pull request New
289 Open 1,734 Closed
289 Open 1,734 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] Support DescribeTabletServers API for safe scaling and upgrades
#3743 opened Jul 22, 2026 by morazow Contributor • Draft
1
[server] Recognize Hadoop missing snapshot files
#3742 opened Jul 22, 2026 by wolfkill Loading…
1
[FLUSS-3716] Tolerate removed tablet servers in wait helpers
#3739 opened Jul 22, 2026 by wolfkill • Draft
[filesystem] avoid zero-skip loop in HadoopDataInputStream
#3738 opened Jul 22, 2026 by wolfkill • Draft
1
[server] release remote log index cache entries on deletion
#3737 opened Jul 22, 2026 by zuston Member Loading…
[server] prevent remote log cache size overflow
#3734 opened Jul 22, 2026 by zuston Member Loading…
[server] include time index in remote log cache weight
#3733 opened Jul 22, 2026 by zuston Member Loading…
1
[FLUSS-1027] Stabilize KvSnapshotITCase snapshot triggering
#3731 opened Jul 22, 2026 by wolfkill • Draft
1
1
[docs] Fix Flink docs anchors and Java 8 build note
#3729 opened Jul 22, 2026 by wolfkill • Draft
[CI] Split Spark lake tests to reduce pipeline time
#3717 opened Jul 21, 2026 by litiliu Contributor Loading…
1 of 2 tasks
2
[test] Tolerate removed tablet servers FlussClusterExtension helpers
#3715 opened Jul 21, 2026 by fresh-borzoni Member Loading…
1
1
[rust][client] Support comma-separated bootstrap servers
#3711 opened Jul 21, 2026 by slfan1989 Contributor Loading…
1
14
[flink] Optimize failover recovery for idempotent aggregations
#3706 opened Jul 20, 2026 by platinumhamburg Contributor Loading…
1
[test] Wait for server tag cleanup
#3705 opened Jul 20, 2026 by litiliu Contributor Loading…
1 task done
1
[server] Fix spurious ISR shrink after leader election
#3702 opened Jul 20, 2026 by fxbing Contributor Loading…
1
1
[filesystem] Align Hadoop dependencies to 3.4.3
#3699 opened Jul 20, 2026 by litiliu Contributor • Draft
1 task done
1
[CI] Reduce the ITCase coverage in Flink to avoid 60min timeout
#3692 opened Jul 19, 2026 by Guosmilesmile Contributor Loading…
9
[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…
[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
6
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
[flink] Fix TableNotExistException when listing partitions on changelog / binlog virtual tables
#3641 opened Jul 13, 2026 by naivedogger Contributor Loading…
1
4
ProTip! Mix and match filters to narrow down what you’re looking for.