Skip to content

Pull requests: apache/fluss

New pull request New
142 Open 976 Closed
142 Open 976 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

fluss-1765: Check if request is removed from inflight requests when connection is closed.
#2127 opened Dec 8, 2025 by vamossagar12 Loading…
1
[server] support database level buckets limit
#2126 opened Dec 8, 2025 by caozhen1937 Loading…
1
[client] Add another queue for re-enqueue operation only in LookupSender to avoid deadlocks during re-enqueue
#2122 opened Dec 8, 2025 by swuferhong Loading…
1
[kv/auto increment column]: Add an implementation of AutoIncIDBuffer
#2119 opened Dec 7, 2025 by vamossagar12 Loading…
1
1
[kv/auto increment column] constrain upsert behavior for auto increment column
#2117 opened Dec 7, 2025 by xx789633 Loading…
1
1
[test] Fix unstable FlinkSinkWriterTest.testFlussSchemaChange test method.
#2116 opened Dec 7, 2025 by zhuangchong Loading…
1
[FLUSS-2113][build] Upgrade Deployed Maven to Latest Stable Release
#2115 opened Dec 6, 2025 by rionmonster • Draft
1
1
[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
[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
1
[flink] Fix data lake catalog connection resource is not closed in flink catalog
#2087 opened Dec 3, 2025 by zhuangchong Loading…
[Flink] fix not compatible with Flink 1.18 and 1.19 (java.lang.NoSuchFieldError: MATERIALIZED_TABLE)
#2083 opened Dec 3, 2025 by sd4324530 Loading…
1
1
[metric] Add user level metrics for byteIn and byteOut
#2080 opened Dec 2, 2025 by zcoo Loading…
1
[common] Introduce ROW type for ARROW, COMPACTED and INDEXED formats
#2079 opened Dec 2, 2025 by XuQianJin-Stars Loading…
1
[common] Remove TableInfo from Cluster
#2068 opened Dec 2, 2025 by swuferhong Loading…
1
[flink] fix ClassNotFoundException MultipleParameterTool
#2063 opened Dec 2, 2025 by sd4324530 Loading…
1
2
[Log] Improve internals of LogScanner by lazily deserialising from record stream / arrow buffer
#2061 opened Dec 1, 2025 by leekeiabstraction • Draft
1
1
[hotfix] Update paimon version to 1.3.1 in fluss quickstart
#2058 opened Dec 1, 2025 by zhuangchong Loading…
fluss-iceberg blog part-1
#2057 opened Nov 30, 2025 by MehulBatra Loading…
4
[iceberg] support altering table properties
#2043 opened Nov 27, 2025 by nastra Loading…
2
[Flink] Support Partial Updates to the Flink Sink
#2042 opened Nov 27, 2025 by polyzos Loading…
5
[lake] Use file to store lake snapshot
#2037 opened Nov 27, 2025 by luoyuxia • Draft
1
30
ProTip! Filter pull requests by the default branch with base:main.