Issues

• [server] Support parallel follower recovery per data directory

  apache/fluss#4914 · Filter by author fxbing opened on Oct 27, 2026

• [test] ConsumerOffsetTableITCase fails after system table cleanup

  apache/fluss#4912 · Filter by author fxbing opened on Oct 27, 2026

• [helm] Publish not-ready addresses on the tablet headless Service so restarting servers stay resolvable

  Task

  apache/fluss#4911 · Filter by author polyzos opened on Oct 27, 2026 · v1.1
  1

• [client] KV batch scans keep using a stale leader after failover

  apache/fluss#4909 · Filter by author fxbing opened on Oct 27, 2026

• [test] Unstable test EnableFlussOnLakeTableProcedureITCase.testReenableExistingTableWithRegisteredSnapshot

  apache/fluss#4907 · Filter by author github-actions opened on Oct 27, 2026

• [rpc] Immediate connection failure can leave a disconnected connection cached

  Bug

  apache/fluss#4904 · Filter by author beryllw opened on Oct 27, 2026

• [flink] Support historical partition batch union reads

  Feature

  apache/fluss#4903 · Filter by author beryllw opened on Oct 27, 2026

• [spark] Support batch and streaming reads of historical partitions

  Feature

  apache/fluss#4902 · Filter by author beryllw opened on Oct 27, 2026

• [helm] Publish each listener's advertised address as a pod environment variable

  apache/fluss#4894 · Filter by author morazow opened on Oct 26, 2026

• [Feature] Support adding nested fields to ROW and ARRAY<ROW> columns

  Feature

  apache/fluss#4889 · Filter by author raoluSmile opened on Oct 26, 2026
  1

• [rust] Add reusable UnionRead source boundaries

  apache/fluss#4886 · Filter by author naivedogger opened on Oct 26, 2026

• [lake/lance] Support ADD COLUMN schema evolution for Lance lake catalog

  apache/fluss#4885 · Filter by author dstolis opened on Oct 26, 2026

• [client] Push projection into Arrow loading for remote log scans

  Feature

  apache/fluss#4882 · Filter by author loserwang1024 opened on Oct 26, 2026
  

• [rust] Projection fails when reading remote logs with older schemas

  Bug

  apache/fluss#4880 · Filter by author spoon-lz opened on Oct 26, 2026

• [log] Writer expiration ignores the injected clock

  apache/fluss#4878 · Filter by author fxbing 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] Convert JSON Produce values with Jackson streaming API

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

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

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