Skip to content

Pull requests: apache/fluss

New pull request New
151 Open 990 Closed
151 Open 990 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

[lake/paimon] Add ARRAY type support for Fluss-Paimon row conversion
#2166 opened Dec 13, 2025 by binary-signal Loading…
safe writes for array
#2165 opened Dec 12, 2025 by binary-signal Loading…
1
1
Prevent Endangered ISR from Losing Leader Permanently
#2163 opened Dec 12, 2025 by platinumhamburg Loading…
1
[kv]: Add an implementation of AutoIncIDBuffer
#2161 opened Dec 12, 2025 by beryllw • Draft
1
5
[common] Fix ArrayIndexOutOfBoundsException in .toArray() methods
#2158 opened Dec 12, 2025 by binary-signal Loading…
1
1
[docs]Add warning message in Deploying Local Cluster
#2156 opened Dec 11, 2025 by Jackeyzhe Loading…
1
[flink] Flink Source need to check tableId on recovery in case that table is recreated.
#2154 opened Dec 11, 2025 by loserwang1024 Loading…
1
1
[flink] Get table info of primary lake table.
#2152 opened Dec 11, 2025 by loserwang1024 Loading…
1
1
[Coordinator] Log the reason for failures in bucket or replica state changes
#2145 opened Dec 11, 2025 by platinumhamburg Loading…
1
3
[Helm] ServiceAccount for TabletServer, CoordinatorServer
#2142 opened Dec 10, 2025 by Paritosh-Anand Loading…
1
1
[test][flink] Fix Unstable test FlinkTableSinkITCase.testVersionMergeEngineWithTypeTimestampLTZ9
#2139 opened Dec 10, 2025 by loserwang1024 Loading…
1
[bug] switch to at.yawk.lz4:lz4-java due to CVE-2025-12183
#2136 opened Dec 10, 2025 by sd4324530 Loading…
1
[server] Reorganize the update mechanisms for logStartOffset, localStartOffset, and remoteLogStartOffset
#2135 opened Dec 9, 2025 by LiebingYu Loading…
1
Support Exactly-Once Semantics for Aggregation Merge Engine
#2134 opened Dec 9, 2025 by platinumhamburg Loading…
1
[RPC] Add a retry mechanism for idempotent interface requests
#2132 opened Dec 9, 2025 by sd4324530 Loading…
1
update Java version requirements in deployment documentation for clarity
#2131 opened Dec 9, 2025 by HarshMehta112 Loading…
1
fluss-1765: Check if request is removed from inflight requests when connection is closed.
#2127 opened Dec 8, 2025 by vamossagar12 Loading…
1
1
[server] support database level buckets limit
#2126 opened Dec 8, 2025 by caozhen1937 Loading…
1
6
[kv/auto increment column]: Add an implementation of AutoIncIDBuffer
#2119 opened Dec 7, 2025 by vamossagar12 Loading…
1
2
[FLUSS-2091][common] Introduced Cycle Detection During Exception Suppression
#2112 opened Dec 6, 2025 by rionmonster Loading…
1
[flink] Flink source support detect new buckets for existing table or partition
#2109 opened Dec 5, 2025 by LiebingYu Loading…
1
[kv] Supports compacted row as change log
#2108 opened Dec 4, 2025 by luoyuxia Loading…
1
4
[core] Support rename table.
#2106 opened Dec 4, 2025 by zhuangchong Loading…
[KV] Support Ignoring UPDATE_BEFORE Records in Changelog for Primary Key Tables
#2105 opened Dec 4, 2025 by platinumhamburg Loading…
1
1
[server] Not permitted to enable datalake for tables created prior to the cluster being set to datalake format
#2100 opened Dec 4, 2025 by LiebingYu Loading…
1
2
ProTip! Updated in the last three days: updated:>2025-12-10.