Skip to content

Pull requests: apache/fluss

New pull request New
145 Open 1,110 Closed
145 Open 1,110 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

Helm charts related fixes
#2374 opened Jan 14, 2026 by morazow • Draft
[FLUSS-2301] Fail Log Scanner when table is dropped during scan
#2373 opened Jan 14, 2026 by Prajwal-banakar Loading…
1
[server] When applying projection pushdown, return empty records instead of skipping them to ensure offset movement in the client.
#2370 opened Jan 14, 2026 by loserwang1024 Loading…
[lake] Add IT case for union read with evolved schema in Paimon tiering
#2368 opened Jan 13, 2026 by ZuebeyirEser Loading…
1
7
[lake/iceberg] Support MAP type in Iceberg tables
#2367 opened Jan 13, 2026 by pithecuse527 Loading…
5
[lake] Support alter table.datalake.freshness
#2365 opened Jan 13, 2026 by zhaomin1423 Loading…
1
8
[lake] Make FlussLakeTiering pluggable to customize tiering job const…
#2364 opened Jan 13, 2026 by luoyuxia Loading…
1
3
[hotfix] Add missing authentication for CoordinatorService RPC calls
#2359 opened Jan 13, 2026 by LiebingYu Loading…
2
[spark] Add spark streaming write support
#2357 opened Jan 13, 2026 by Yohahaha Loading…
4
feat(cli): add Fluss CLI module with comprehensive test coverage
#2356 opened Jan 12, 2026 by gnuhpc Loading…
Rebalance procedure docs
#2355 opened Jan 12, 2026 by swuferhong Loading…
1
Upgrade GitHub Actions for Node 24 compatibility
#2349 opened Jan 12, 2026 by sd4324530 Loading…
[flink] changelog read support for pk table without pushdown optimizations
#2347 opened Jan 11, 2026 by MehulBatra Loading…
1
1
[lake/lance] Refactor LanceArrowWriter
#2345 opened Jan 11, 2026 by XuQianJin-Stars Loading…
1
1
[flink] Change the ListRebalanceProcessProcedure result from String[] to row[]
#2341 opened Jan 10, 2026 by sd4324530 Loading…
1
20
[hotfix][helm] Update image repository to use apache/fluss instead of fluss
#2340 opened Jan 9, 2026 by morazow Loading…
1
[lake/paimon] Compare paimon schema and Fluss schema before alter table.
#2331 opened Jan 8, 2026 by loserwang1024 Loading…
1
9
[paimon] Fix union read paimon dv table issue
#2326 opened Jan 8, 2026 by luoyuxia Loading…
1
2
[common]Add Early Validation for Aggregation Function Data Types During Table Creation
#2323 opened Jan 7, 2026 by Jackeyzhe Loading…
1
[observability] introduce prometheus-push mode
#2317 opened Jan 6, 2026 by zuston Loading…
1
[spark] Add Spark show/add/drop partition support
#2314 opened Jan 6, 2026 by Yohahaha Loading…
14
Add assertions in CompactedKeyEncoderTest to maintain parity with Rust client test
#2312 opened Jan 5, 2026 by leekeiabstraction Loading…
7
Flink Intergration of Aggregation Merge Engine
#2307 opened Jan 5, 2026 by platinumhamburg Loading…
1
6
Fix flaky ReplicaTest.testRestore
#2303 opened Jan 4, 2026 by Gautam-aman Loading…
1
6
[helm] correct the internal listening address configuration for coordinator-server
#2290 opened Dec 30, 2025 by bbb4aaa Loading…
ProTip! Updated in the last three days: updated:>2026-01-11.