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

Support Multi-Location for Remote Storage Open

apache/fluss#2292 · 0 comments · 1 reaction · 1 assignee · Indexed Sep 14, 2026
Partial Update use column id rather column position to update data. Open

apache/fluss#2293 · 5 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Change the kvSnapshotLeaseCount as a table level metrics Open

apache/fluss#2297 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Drop a table during log scanner scan records should fail the scanner Open

apache/fluss#2301 · 4 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Implements projection pushdown for nested row. Open

apache/fluss#2311 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[rebalance] Refactor ReplicaLeaderElection into interface with method leaderElection Open

apache/fluss#2324 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rebalance] Support rebalancePlan interface in Admin Open

apache/fluss#2327 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
JavaVersion.JAVA_9 Open

apache/fluss#2351 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Limit Scan will emit wrong data for partitioned table in partition filter scan Open

apache/fluss#2353 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Handle individual table failures without failing the entire job Open

apache/fluss#2360 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Add more strict check for enable datalake Open

apache/fluss#2361 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Allow user to track the tiering status of a tiering table Open

apache/fluss#2362 · 19 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Unstable testListRebalanceProgress Open

apache/fluss#2372 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Aggregation] Add collect/merge_map aggregation support Open

apache/fluss#2387 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Row UPDATE not working (PK Table) Open

apache/fluss#2397 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[codegen] Add fluss-codegen module for runtime code generation Open

apache/fluss#2398 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/lance] Map type support for Lance Open

apache/fluss#2403 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rebalance] Rebalancing with the PERMANENT_OFFLINE server tag may result in leaders not being migrated away Open

apache/fluss#2405 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Need Support for Schema Evolution (Table Structure Changes) Open

apache/fluss#2410 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella][FIP-27] Remove Mandatory System Columns From Fluss Lake Tables Open

apache/fluss#2411 · 3 comments · 1 reaction · 1 assignee · Indexed Sep 14, 2026
Add support of iceberg 1.4.3 as a independent module Open

apache/fluss#2414 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/iceberg] IcebergLakeCommitter Can Block Indefinitely During Simultaneous Rewrite Operations Open

apache/fluss#2420 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Server] Missing table_bucket_lakeTiering Metrics for Lake-Enabled Tables Open

apache/fluss#2422 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[KV] Add Configuration Option to Control RocksDB Statistics Collection Open

apache/fluss#2435 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/tiering] Add More Tiering Monitoring Metrics Open

apache/fluss#2439 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Invalid timeout for ReplicaFetcherThread Open

apache/fluss#2451 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Optimize CompletedSnapshotStoreManager memory usage by using relative paths Open

apache/fluss#2486 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
TieringService will stuck when drop the table that is tiering Open

apache/fluss#2498 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Support report backlog information to Flink Open

apache/fluss#2509 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Exclude hadoop dep in fluss-fs-hdfs module Open

apache/fluss#2511 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Fluss server support multiple-paths for remote storage Open

apache/fluss#2517 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support independent authentication for multiple remote paths Open

apache/fluss#2518 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
lookupBy should align with the method name to support do primary key lookup Open

good first issue

apache/fluss#2521 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[spark] improve streaming read support Open

apache/fluss#2527 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Add rate limit for streaming read Open

apache/fluss#2550 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Support new/delete partition in streaming read Open

apache/fluss#2551 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Add streaming metrics Open

apache/fluss#2552 · 4 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[spark] Support streaming read with latest mode Open

apache/fluss#2553 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[UMBRELLA] Prepare Apache Fluss for Incubating Graduation Open

apache/fluss#2562 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[helm] Enable external connectivity in the helm charts Open

apache/fluss#2574 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test FlinkUnionReadLogTableITCase.testReadLogTableInStreamMode Open

apache/fluss#2580 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test FlussAuthorizationITCase. testInitWriter Open

apache/fluss#2581 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[DOCS] Enhance ConfigOptionsDocGenerator for cleaner MDX output and fixed formatting Open

apache/fluss#2586 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] Upgrade flink docker image version to latest Flink 2.2 for quickstarts Open

apache/fluss#2596 · 7 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[kv snapshot lease] Reduce the external IO operation when send source event to coordinator when FlinkSourceReader do snapshot state Open

apache/fluss#2597 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kv snapshot lease] Check whether the snapshot is exists when acquireLease in KvSnapshotLeaseMnanager Open

apache/fluss#2600 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kv snapshot lease] Resue the ScheduledExecutorService of KvSnapshotManager and ProducerOffsetsManager Open

apache/fluss#2602 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kv snapshot lease] refactor the lock of KvSnapshotManager#acquireLease Open

apache/fluss#2603 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Lake/Iceberg] create doc to integrate fluss + Iceberg via flink with Hive Open

apache/fluss#2614 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[lake/iceberg] Support v3 table format with Equality delete Open

apache/fluss#2615 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026

apache/fluss

Get new issues in your inbox