Issues

• [lake/paimon] Allow passing an existing table to PaimonLakeSource

  apache/fluss#4957 · Filter by author bryndenZh opened on Oct 30, 2026

• [server] Slow snapshot directory creation blocks KV writes

  apache/fluss#4953 · Filter by author fxbing opened on Oct 30, 2026

• [flink] Advance idle bucket baselines after successful Undo Recovery

  apache/fluss#4952 · Filter by author platinumhamburg opened on Oct 30, 2026

• [test] Unstable test ConsumerOffsetTableITCase.testExternalRequestCannotCreateSystemTable

  apache/fluss#4950 · Filter by author github-actions opened on Oct 30, 2026
  1

• [test] Unstable test TabletServiceITCase.testProduceLog

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

• [kafka] Kafka listener channels bypass RequestChannel backpressure

  apache/fluss#4943 · Filter by author dao-jun opened on Oct 29, 2026

• [rpc] Channels registered during active backpressure are never paused

  apache/fluss#4942 · Filter by author dao-jun opened on Oct 29, 2026

• [lake/iceberg] Truncated position-delete bounds break compaction

  Bug

  apache/fluss#4940 · Filter by author polyzos opened on Oct 29, 2026
  2

• [lake/paimon] Create Fluss tables from existing Paimon primary-key tables

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

• [lake/iceberg] Support composite bucket keys for Iceberg-tiered tables

  Feature

  apache/fluss#4936 · Filter by author polyzos opened on Oct 29, 2026
  2

  

• [Bug] Altering table config fails when datalake is disabled

  apache/fluss#4934 · Filter by author litiliu opened on Oct 29, 2026
  2

• [flink] DataStream FlussSource shares one KV snapshot lease ID per JVM, so one job can drop or overwrite another job's snapshot lease

  apache/fluss#4930 · Filter by author ymkim1006 opened on Oct 29, 2026

• [client] Metadata initialization failures can leave partition writes stuck

  Bug

  apache/fluss#4928 · Filter by author threadfly2026 opened on Oct 28, 2026

• [server] Lookups queue for seconds behind slow putKv requests in the shared request worker pool

  Feature

  apache/fluss#4926 · Filter by author polyzos opened on Oct 28, 2026
  4

• [Feature] Support InternalRow#createFieldToString

  priority=critical
  apache/fluss#4924 · Filter by author wuchong opened on Oct 28, 2026 · v1.1
  3

  

• [rust] Decode only selected columns in remote Arrow logs

  Feature

  apache/fluss#4921 · Filter by author spoon-lz opened on Oct 28, 2026
  1

• [test] Unstable test KafkaMetadataITCase.testCustomDefaultDatabaseAliasAndNoRecreationByMetadata

  apache/fluss#4920 · Filter by author github-actions opened on Oct 28, 2026
  1

• [kafka] Add Produce request metrics by reusing RequestsMetrics

  apache/fluss#4918 · Filter by author wuchong opened on Oct 27, 2026
  1

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

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

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