Issues

• [lake/iceberg] Pluggable Arrow file writer for tiering append-only tables

  apache/fluss#5226 · Filter by author mikepapadim opened on Nov 13, 2026
  1

• [Improvement] Reduce allocations in HLL sketch merging

  apache/fluss#5224 · Filter by author rahulbsw opened on Nov 13, 2026

• [lake] Let the lake tiering factory declare record batch write support

  apache/fluss#5222 · Filter by author mikepapadim opened on Nov 13, 2026

• [test] Upgrade SeaweedFS S3 test backend to 4.50 to avoid Admin port collisions

  Bug

  apache/fluss#5220 · Filter by author Jackeyzhe opened on Nov 13, 2026

• [helm] Configuration changes on helm upgrade do not restart Fluss pods

  apache/fluss#5217 · Filter by author binary-signal opened on Nov 13, 2026

• [client] Add consumer group owner discovery

  Task

  apache/fluss#5213 · Filter by author pisceslj opened on Nov 13, 2026

• Add a $stream suffix for Fluss-only reads on lake-enabled tables

  Feature

  apache/fluss#5211 · Filter by author loserwang1024 opened on Nov 13, 2026
  

• [flink] Lookup join drops matches when a join key filtered after the lookup is BINARY/BYTES

  Bug

  apache/fluss#5208 · Filter by author jx2lee opened on Nov 13, 2026

• [rust] Add log batch CRC validation

  Feature

  apache/fluss#5206 · Filter by author spoon-lz opened on Nov 13, 2026

• [server] Implement consumer group management APIs

  Task

  apache/fluss#5202 · Filter by author pisceslj opened on Nov 13, 2026

• [rust] Add explicit consumer offset commits and restore

  apache/fluss#5200 · Filter by author naivedogger opened on Nov 13, 2026

• [spark] PK incremental reads fail when retention removes planned offsets

  apache/fluss#5199 · Filter by author litiliu opened on Nov 13, 2026
  1

• [Umbrella][rust] Consumer offset management and language bindings

  apache/fluss#5198 · Filter by author naivedogger opened on Nov 13, 2026

• [lake/iceberg] PK Tables with WAL changelog image keep stale rows in Iceberg

  Bug

  apache/fluss#5194 · Filter by author wattt3 opened on Nov 12, 2026

• Last ISR replica loses acknowledged rows after a TabletServer crash

  apache/fluss#5190 · Filter by author fresh-borzoni opened on Nov 12, 2026

• [rust] Read only selected Arrow buffers from remote log files

  apache/fluss#5189 · Filter by author fresh-borzoni opened on Nov 12, 2026

• [rust] Log scanner doesn't check batch CRCs

  apache/fluss#5188 · Filter by author fresh-borzoni opened on Nov 12, 2026

• [server] Add a cluster feature gate to enable V3 log record batches

  apache/fluss#5187 · Filter by author dstolis opened on Nov 12, 2026

• [rust] Integration tests don't check write results

  apache/fluss#5185 · Filter by author fresh-borzoni opened on Nov 12, 2026

• [server] Expose per-TabletServer software versions in Admin.describeCluster()

  Feature

  apache/fluss#5183 · Filter by author swuferhong opened on Nov 12, 2026
  

• [kv] Optimize distinct array aggregations

  apache/fluss#5181 · Filter by author platinumhamburg opened on Nov 12, 2026

• [flink] Report pendingRecords for KV snapshot and lake splits

  Feature

  apache/fluss#5180 · Filter by author polyzos opened on Nov 12, 2026

• [spark] Spark UT fails to compile on Windows

  apache/fluss#5177 · Filter by author ChengbingLiu opened on Nov 12, 2026

• [kv] Support distinct elements in last_n aggregation

  apache/fluss#5172 · Filter by author platinumhamburg opened on Nov 12, 2026

• [server] Delayed deletion updates can remove metadata for a recreated table or partition

  Bug

  apache/fluss#5171 · Filter by author swuferhong opened on Nov 12, 2026 · v1.1