apache/fluss

View on GitHub

Apache Fluss is a streaming storage built for real-time analytics.

Stars: 2.1k
Forks: 625
Open beginner issues: 0
Indexed issues: 628
Avg merge: 2d 20h
Merged PRs (30d): 119

Dominant language: Java
License: Apache-2.0
Last GitHub push: Sep 16, 2026
Latest indexed: Sep 14, 2026
Contributing guide: No contributing guide
Code of conduct: Code of conduct
Beginner labels: good first issue

Open All

619 open issues indexed

[tiering] Slow manifest compaction during lake commit blocks other tables' tiering progress Open

apache/fluss#3259 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] Refactor RemoteLogDownloader to use chunked streaming instead of downloading whole segment file Open

apache/fluss#3262 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[flink] Support hint-based watermark configuration for Flink connector Open

apache/fluss#3265 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Optional channel selection for source split in FlinkSourceEnumerator Open

apache/fluss#3269 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Flink Union Read Test of Hudi Open

apache/fluss#3284 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Rust] Extend the Rust Client to support KvScan Open

component=client

apache/fluss#3294 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[flink] currentFetchEventTimeLag is misleading when subscribing multiple partitions/buckets with uneven lag Open

apache/fluss#3304 · 2 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Fluss binlog source fails checkpoint/savepoint with NPE in FlinkSourceEnumerator.snapshotState Open

apache/fluss#3307 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support independent lake partition spec for lakehouse tiering Open

apache/fluss#3309 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support Partition Mark Done for Fluss Tiering (Paimon Lake) Open

apache/fluss#3314 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Respect the log.* config from the table level options Open

apache/fluss#3315 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Port TreeMap-collapse log buffer to FlussUpsertPartitionReader Open

apache/fluss#3320 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Partition filter pushdown for lake-enabled tables Open

apache/fluss#3321 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[flink] Lake-batch fallback should use KV snapshot instead of reading log from earliest Open

apache/fluss#3327 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[Feature] Add Apache DataSketches sketch aggregation support Open

apache/fluss#3331 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[spark] Umbrella issue to track spark dsv2 interface Open

apache/fluss#3341 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Implement SupportsReportPartitioning Open

apache/fluss#3343 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Implement SupportsRuntimeV2Filtering Open

apache/fluss#3344 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rebalance] Support rate‑limiting‑like effect by controlling number of partitions rebalanced at one time Open

apache/fluss#3348 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
add support of offset lag Open

apache/fluss#3349 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Support altering table.auto-partition.num-precreate Open

apache/fluss#3351 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Support altering table.auto-partition.enabled Open

apache/fluss#3353 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Table deletion stuck permanently when StopReplica request fails Open

apache/fluss#3357 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
clearup useless fluss partition info in writer metadata cache Open

apache/fluss#3362 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Enhanced LanceDB Integration — Vector Indexes, FTS, and Hybrid Search Open

apache/fluss#3366 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Support DROP COLUMN schema evolution Open

apache/fluss#3392 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test after DefaultAuthorizerTest Open

apache/fluss#3394 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rust] Merge fluss-rust repo into fluss Open

apache/fluss#3407 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[flink] Preserve tiering offsets for empty-batch buckets Open

apache/fluss#3413 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add per-scanner dimension for scanner metrics Open

apache/fluss#3415 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[tiering] Support reporting watermark to Paimon snapshot Open

apache/fluss#3419 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Projection Pushdown with Newly Added Columns Fails for Old Batches Open

apache/fluss#3423 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Limit the scope and semantics of startup.mode Open

apache/fluss#3426 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support implicit/hidden partitions for Fluss tables Open

apache/fluss#3435 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add Admin API and sys procedure to describe bucket metadata Open

apache/fluss#3436 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test CommitRemoteLogManifestITCase.testDeleteOutOfSyncReplicaLogAfterCommit Open

apache/fluss#3440 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test PaimonTieringITCase.testTiering Open

apache/fluss#3445 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Flink] Add support for partition pruning to the Datastream API Open

apache/fluss#3452 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[server] complete delayed fetch operations after produce to reduce fetch latency Open

apache/fluss#3455 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Refactor the jittered partition creation logic in AutoPartitionManager to TableLifecycleThrottler Open

apache/fluss#3457 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test RemoteLogDownloaderTest.testPrefetchNum Open

apache/fluss#3460 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[ui] Support Fluss UI for database and table management Open

apache/fluss#3461 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] use CamelCase in spark configs Open

apache/fluss#3462 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test FlinkUnionReadPrimaryKeyTableITCase.testUnionReadInStreamMode Open

apache/fluss#3465 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server][client] Partition expiration storms ZooKeeper via repeated GET_METADATA on non-existent partitions until enumerator unsubscribes Open

apache/fluss#3466 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[test] Unstable test Flink120TableSourceBatchITCase.testCountPushDownForLogTable Open

apache/fluss#3478 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Clean orphan children under unknown databases Open

apache/fluss#3488 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support safe cleanup of orphaned KV shared SST files Open

priority=blocker

apache/fluss#3489 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake] Union read on partitioned table returns duplicated rows when partition column is non-String type Open

apache/fluss#3490 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Feature] Support SASL/OAUTHBEARER authentication for Fluss RPC Open

apache/fluss#3495 · 3 comments · 2 reactions · 0 assignees · Indexed Sep 14, 2026

apache/fluss

Get new issues in your inbox