Issues

• [lake] Stop retrying permanently failing tiering commits forever

  component=lake/tiering-flinkcomponent=lake
  apache/fluss#5242 · Filter by author polyzos opened on Nov 15, 2026

• [lake/tiering] Catch-up can stall when a remote segment download takes longer than a tiering round

  Bug

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

• [lake] Readers don't see a compacted lake snapshot until the next tiering commit

  apache/fluss#5240 · Filter by author polyzos opened on Nov 15, 2026

• [client] Closing a KV snapshot scanner does not stop its download

  apache/fluss#5239 · Filter by author polyzos opened on Nov 15, 2026

• [server] Prevent stale pushed metadata updates across reconnects

  apache/fluss#5238 · Filter by author SteNicholas opened on Nov 15, 2026

• [client][server] Support range filtering in Admin.listPartitionInfos

  Feature

  apache/fluss#5236 · Filter by author yangshangqing95 opened on Nov 15, 2026

• [lake/paimon] Tiering abort deletes data files that are still in the table

  apache/fluss#5235 · Filter by author fresh-borzoni opened on Nov 14, 2026
  1

• [flink] Sink flush before each checkpoint makes checkpoints slow under write backpressure

  apache/fluss#5234 · Filter by author polyzos opened on Nov 14, 2026

• [metrics] Expose KV write lock wait time for putKv

  apache/fluss#5233 · Filter by author polyzos opened on Nov 14, 2026

• [kv] Read existing values for a putKv batch before taking the KV write lock

  apache/fluss#5232 · Filter by author polyzos opened on Nov 14, 2026

• [server] Keep KV recovery and retention on the same snapshot

  apache/fluss#5228 · Filter by author platinumhamburg opened on Nov 14, 2026

• [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
  1