Commits · apache/fluss

📝 Commits on main

Commits on January 21, 2026

[client] move OffsetsInitializer to fluss-client (#2424)

Yann Byron committed 3 hours ago

bb84256

Commits on January 20, 2026

[kv] Add roaring bitmap aggregate function for aggregation merge engine (#2390)

Yang Wang committed 1 days ago

864bbe6

[flink] Flink integration with Aggregation Merge Engine (#2307)

Yang Wang committed 1 days ago

d10cb35

[lake] Support alter table.datalake.freshness (#2365)

zhaomin1423 committed 1 days ago

2fc820d

Commits on January 19, 2026

[docs] Add docs for rebalance (#2382)

yunhong committed 2 days ago

7cdb733

[hotfix] Fix union read fail when from timestamp and projection enabled (#2383)

yuxia Luo committed 2 days ago

04470ee

[tests] Cleanup ZK state in TableChangeWatcherTest to not let current tests be impacted by leftover events from previous tests. (#2249)

vamossagar12 committed 2 days ago

a8308b5

Commits on January 17, 2026

[flink] Fix the distribution mode support for FlussSink for DataStream API

Jark Wu committed 3 days ago

4f3c457

[flink] Optimize sink statistics calculation to run only when necessary

Jark Wu committed 4 days ago

029bc13

[server] Prevent remote log TTL expiration until tiering completes (#1940)

Liebing committed 3 days ago

a6b0b85

[kv] Improve the implementation of AUTO_INCREMENT column

Jark Wu committed 4 days ago

be01cff

[lake/lance] Refactor LanceArrowWriter to reuse fluss-common ArrowWriters (#2345)

ForwardXu committed 4 days ago

8799308

[spark] Add Spark show/add/drop partition support (#2314)

Yang Zhang committed 4 days ago

053b8f7

Commits on January 15, 2026

[flink] Support PARTITION_DYNAMIC sink dynamic shuffle based on partition traffics (#1784)

Hongshun Wang committed 6 days ago

13af6bf

[Flink] Support Partial Updates to the Flink Sink (#2042)

Giannis Polyzos committed 6 days ago

c9370ae

Rebalance procedure docs (#2355)

yunhong committed 6 days ago

3c53a20

[paimon] Add IT case for union read with evolved schema for Paimon (#2368)

Zübeyir Eser committed 6 days ago

d2ac422

[lake] Re-initial tiering splits for tables if reader failover happen (#1984)

Junbo Wang committed 6 days ago

2ce8378

Commits on January 18, 2026

[test] Fix unstable test RebalanceITCase#testRebalanceForLogTable (#2407)

yunhong committed 3 days ago

42ccb87

Add RocksDB block cache configuration options for index and filter blocks (#2394)

Yang Wang committed 3 days ago

e4f694d

[spark] Add spark streaming write support (#2357)

Yang Zhang committed 3 days ago

344e38f

Commits on January 6, 2026

[kv] Add basic implementation of AUTO_INCREMENT column (#2161)

Junbo Wang committed 15 days ago

dc8cc65

Commits on January 16, 2026

Change the ListRebalanceProcessProcedure result from String[] to row[] (#2341)

Pei Yu committed 5 days ago

c1f7a11

Commits on January 14, 2026

[doc] fix typo of 'table.datalake.enabled' in options.md (#2366)

zhaomin1423 committed 7 days ago

4dba604

Commits on January 12, 2026

[hotfix] Add authentication to the admin APIs that currently lack it (#2350)

yunhong committed 8 days ago

8b11e00

[docs] Add alter table feature link in getting-started.md (#2348)

yunhong committed 9 days ago

7fd7b33

[Task] Enhance tests for cluster rebalancing (#2315) (#2337)

Prajwal banakar committed 9 days ago

3db4bfe

Commits on January 11, 2026

[kv] include hidden potential internal flush time in KV flush latency (#2206)

Junfan Zhang committed 9 days ago

2b0e2b1

[spark] Fix spark desc command output with partition info (#2313)

Yang Zhang committed 10 days ago

a1b8204

Jark Wu committed 10 days ago

02115e6