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: 3d 14h
Merged PRs (30d): 97

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

621 open issues indexed

TieringCommitOperator: Non-atomic dual commit can expose wrong “latest” snapshot for visibility Open

apache/fluss#2625 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[IT][Bug]ServerITCaseBase fails when stderr contains "Picked up JAVA_TOOL_OPTIONS" Open

apache/fluss#2631 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[tiering][lake] Race: duplicate commits possible if heartbeat times out but job still commits (after missing‑snapshot check) Open

apache/fluss#2648 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Infinite log retention Open

apache/fluss#2653 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[filesystem] Enhance S3 filesystem with independent credentials provider for token delegation Open

apache/fluss#2662 · 6 comments · 4 reactions · 1 assignee · Indexed Sep 14, 2026
[spark] to support Spark4.x Open

apache/fluss#2666 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] refine the format when desc table Open

apache/fluss#2675 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] Reintroduce the fluss-quickstart-flink Docker image Open

apache/fluss#2683 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Fix SASL client special characters escaping Open

apache/fluss#2698 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] Lance Quickstart documentation with vector search example Open

apache/fluss#2705 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Adjust ZooKeeper session timeout to prevent ISR shrink before leader failover Open

apache/fluss#2708 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
When enabled, JMX metrics reporter throws exception on startup Open

apache/fluss#2712 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/lance] Support Union Read query against Lance table Open

apache/fluss#2715 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] OutOfMemoryError when startTaskManager in Flink IT case Open

apache/fluss#2744 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Dedicated tiering service for specified table Open

apache/fluss#2745 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Timeout for fetch log request Open

apache/fluss#2749 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
KV tablet should not produce log via PRODUCE_LOG Open

apache/fluss#2750 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/lance] Support Flink SQL batch query against Lance table Open

apache/fluss#2751 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Update Tablet Server to use per-table/partition remote data directory Open

apache/fluss#2756 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[flink] Rewrite waitForCheckpoint, getFileBasedCheckpointsConfig to a shared base class Open

apache/fluss#2758 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[server] Fix NPE in releaseBucket when table lease is not found Open

apache/fluss#2771 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] RemoteStorageCleaner support clean for multiple remote directories Open

apache/fluss#2785 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug][Lake][Paimon] Fix the situation where resources may not be free up when reading paimon Open

apache/fluss#2790 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add compression for CompactedRow Open

component=log

apache/fluss#2806 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Flaky Test: KvSnapshotBatchScannerITCase.testKvSnapshotLease Open

apache/fluss#2807 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] The table in the document is misaligned Open

apache/fluss#2812 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support more dynamic cluster configuration Open

apache/fluss#2818 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support download latest kv snapshot from remote while becoming standby replica Open

apache/fluss#2830 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[server] Use per-table remote data directory when storing lake table offset files Open

apache/fluss#2832 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] Update s3.region in quickstart docs of flink and lakehouse Open

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

apache/fluss#2854 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Helm] Restructure helm chart of Fluss Open

apache/fluss#2865 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test IcebergRewriteITCase.testLogTableCompaction Open

apache/fluss#2867 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test CoordinatorEventProcessorTest.testCreateAndDropPartition Open

apache/fluss#2868 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support for VARIANT data type Open

apache/fluss#2873 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test Flink119TableSourceITCase.testLookupInsertIfNotExists Open

apache/fluss#2874 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Throttle replica deletion on Coordinator startup to prevent event queue starvation Open

apache/fluss#2891 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] Write sender I/O thread crashes with "Accounted size went negative" due to Arrow memory double-release in ArrowWriter Open

apache/fluss#2892 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[flink] Support Union Read via Flink DataStream API Open

apache/fluss#2895 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
support kv snapshot lease in tiering service Open

apache/fluss#2898 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[test] Unstable test TableChangeWatcherTest.testTableRegistrationChange Open

apache/fluss#2903 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test AdjustIsrITCase.testIsrShrinkAndExpand Open

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

apache/fluss#2910 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test KvReplicaRestoreITCase.testRestore Open

apache/fluss#2911 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kv] Implement KvTablet RocksDB Lazy Open Open

apache/fluss#2913 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[tiering] Tiering Job Performance: Read-Write Pipeline Optimization Open

apache/fluss#2915 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[KV] Add retract support for Aggregation Merge Engine Open

apache/fluss#2916 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add AGENTS.md coding guide for AI agents Open

apache/fluss#2921 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test Flink119TableSinkITCase.testWritePartitionedTable Open

apache/fluss#2937 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test BatchScannerITCase.testScanSnapshot Open

apache/fluss#2938 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026

apache/fluss

Get new issues in your inbox