Issues

• [Bug] Daemon shutdown timeout message reports 10 seconds instead of 120

  Bug

  apache/fluss#4871 · Filter by author shuyouZZ opened on Oct 26, 2026

• [elixir] Use keyword options with false defaults in Fluss.Admin

  Task

  apache/fluss#4867 · Filter by author nicolazar opened on Oct 25, 2026

• [rust] Writes to a missing partition retry forever and block other new partitions

  Bug

  apache/fluss#4866 · Filter by author nicolazar opened on Oct 25, 2026

• [kafka] Miscellaneous Kafka compatibility improvements

  apache/fluss#4864 · Filter by author gyang94 opened on Oct 25, 2026

• [kafka] Convert JSON Produce values with Jackson streaming API

  apache/fluss#4863 · Filter by author wuchong opened on Oct 25, 2026

• [rust] Lookup requests are not drained when batch timeout is zero

  Bug

  apache/fluss#4862 · Filter by author slfan1989 opened on Oct 25, 2026

• [kafka] Prevent Kafka endpoints from starting on CoordinatorServer

  apache/fluss#4859 · Filter by author gyang94 opened on Oct 24, 2026

• [rpc] Isolate internal listener resources from client backpressure

  apache/fluss#4856 · Filter by author platinumhamburg opened on Oct 24, 2026

• [kv] Add bounded TS-level RocksDB cache and read metrics

  apache/fluss#4854 · Filter by author platinumhamburg opened on Oct 24, 2026

• [server] Implement consumer offset commits

  Task

  apache/fluss#4849 · Filter by author pisceslj opened on Oct 24, 2026

• [Umbrella] Implement FIP-25: Promote existing Paimon tables to Fluss

  component=lake/paimon
  apache/fluss#4846 · Filter by author luoyuxia opened on Oct 24, 2026

• [rpc] Measure synchronous request processing time

  apache/fluss#4844 · Filter by author platinumhamburg opened on Oct 23, 2026

• [spark] Improve tiering job observability and round timing

  apache/fluss#4831 · Filter by author Yohahaha opened on Oct 23, 2026

• [spark] Support concurrent table tiering within one Spark application

  apache/fluss#4830 · Filter by author Yohahaha opened on Oct 23, 2026

• [metrics] Define empty-window semantics for expiring histogram reporters

  apache/fluss#4828 · Filter by author platinumhamburg opened on Oct 23, 2026

• [docs] Document the Spark tiering service

  apache/fluss#4818 · Filter by author Yohahaha opened on Oct 23, 2026

• [server] Reduce default writer ID expiration to one day

  apache/fluss#4815 · Filter by author fxbing opened on Oct 23, 2026
  

• [kv] Support global secondary indexes

  apache/fluss#4813 · Filter by author platinumhamburg opened on Oct 23, 2026
  1

• [kv] Support ignoring nulls in upsert requests

  apache/fluss#4811 · Filter by author platinumhamburg opened on Oct 23, 2026

• [kafka] Serve Metadata from the server cache with tablePropertyCache

  apache/fluss#4807 · Filter by author gyang94 opened on Oct 22, 2026
  1

• Support per-partition bucket rescale for Iceberg lake tables

  apache/fluss#4804 · Filter by author litiliu opened on Oct 22, 2026
  1

• [Feature] Expose a partition seal API with write fencing and explicit end-of-stream signaling

  Feature

  apache/fluss#4799 · Filter by author threadfly2026 opened on Oct 22, 2026

• [spark] Expose Fluss table properties in Spark SQL

  Feature

  apache/fluss#4797 · Filter by author shuyouZZ opened on Oct 22, 2026

• [client] Support physical partition id based offset lookup

  Feature

  apache/fluss#4796 · Filter by author yangshangqing95 opened on Oct 22, 2026

• Iceberg tables with multiple bucket keys can be created but cannot be written

  Feature

  apache/fluss#4794 · Filter by author yangshangqing95 opened on Oct 21, 2026
  2