Search results

[flink] Lake-batch fallback should use KV snapshot instead of reading log from earliest

Status: Open.

Task

#3327 In apache/fluss;

· fresh-borzoni opened on May 16, 2026

[spark] Partition filter pushdown for lake-enabled tables

Status: Open.

Task

#3321 In apache/fluss;

· fresh-borzoni opened on May 14, 2026

[spark] Port TreeMap-collapse log buffer to FlussUpsertPartitionReader

Status: Open.

Task

#3320 In apache/fluss;

· fresh-borzoni opened on May 14, 2026

Respect the log.* config from the table level options

Status: Open.

Feature

#3315 In apache/fluss;

· zuston opened on May 14, 2026

[Feature] Support Partition Mark Done for Fluss Tiering (Paimon Lake)

Status: Open.

Feature

#3314 In apache/fluss;

· beryllw opened on May 14, 2026

[server] Prevent deletion of default database to avoid catalog open failure

Status: Open.

Task

#3311 In apache/fluss;

· gyang94 opened on May 13, 2026

Support independent lake partition spec for lakehouse tiering

Status: Open.

Feature

#3309 In apache/fluss;

· litiliu opened on May 13, 2026

Fluss binlog source fails checkpoint/savepoint with NPE in FlinkSourceEnumerator.snapshotState

Status: Open.

Bug

#3307 In apache/fluss;

· lgtm4e opened on May 13, 2026

[flink] currentFetchEventTimeLag is misleading when subscribing multiple partitions/buckets with uneven lag

Status: Open.

Bug

#3304 In apache/fluss;

· loserwang1024 opened on May 12, 2026

[Rust] Extend the Rust Client to support KvScan

component=client

Status: Open.

Feature

#3294 In apache/fluss;

· polyzos opened on May 9, 2026

[Flink] Extend the Flink connector to support KvScan

Status: Open.

Task

#3293 In apache/fluss;

· polyzos opened on May 9, 2026

·  

v1.0

[flink][spark] Partition pruning gives wrong results for non-STRING partition keys with range predicates

Status: Open.

Task

#3292 In apache/fluss;

· fresh-borzoni opened on May 9, 2026