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

Support for Arrow Flight SQL Protocol and ADBC Open

apache/fluss#505 · 0 comments · 16 reactions · 0 assignees · Indexed Sep 14, 2026
The flushKv and updateHighWatermark need to be atomic operation Open

component=log component=server

apache/fluss#513 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Reduce CoordinatorServer memory footprint for kv snapshot Open

component=kv

apache/fluss#528 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Store the relative path instead of absolute path in `KvFileHandle` Open

apache/fluss#530 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add license for all the markdown files Open

apache/fluss#571 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
FlinkTestBase.waitUntilPartitions is not stable Open

apache/fluss#590 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
The server will occur a large number of FetchLogRequest when one tableServer fail down and recovers Open

component=log

apache/fluss#594 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Log data will be truncated to zero when one tabletServer failed Open

component=log

apache/fluss#596 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add some metrics for CompletedSnapshotStoreManager to monitor the remote kv Snapshot Open

component=kv component=metrics

apache/fluss#600 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Support Kafka Protocol 4: Add utils to convert Kafka MemoryRecords Open

apache/fluss#607 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Deploy released Javadocs to website Open

component=docs component=website

apache/fluss#608 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support Kafka Protocol 6: Register kafka server after started Open

apache/fluss#611 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[File system] Allow users to configure STS endpoint for S3 file system Open

component=filesystem

apache/fluss#613 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Include observability quickstart files in binary distribution Open

apache/fluss#614 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[File system] Add `AssumeRoleWithWebIdentity` STS functionality for temporary credentials to S3 file system to support MinIO Open

component=filesystem

apache/fluss#621 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella] Improve Test Code Coverage for Ignored Classes Open

component=test good first issue

apache/fluss#641 · 13 comments · 3 reactions · 1 assignee · Indexed Sep 14, 2026
[Umbrella] Subissue Improve Flink Metrics coverage for Unit and Integration Test Open

apache/fluss#646 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Bump `slf4j-api` version Open

apache/fluss#648 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Improve Test Coverage for Fluss / Flink Connector Open

component=connector/flink component=test

apache/fluss#660 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Error when writing to fluss: IndexOutOfBoundsException Open

apache/fluss#665 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Use Leader Epoch rather than High Watermark for Truncation Open

component=log component=server

apache/fluss#673 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Introduce batchDeliveryTimeout in client to expire batches that have been stuck for a long time Open

component=client

apache/fluss#685 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
LogTieringTask#commitRemoteLogManifest() may block forever when coordinator failover Open

component=rpc

apache/fluss#692 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
When TabletServer clean shutdown, client will throw OutOfOrderSequenceException Open

apache/fluss#709 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Revert LeaderEndOffsetSnapshot Open

apache/fluss#741 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
FlinkSink write to primaryKey table may block forever When upgrading the Fluss cluster Open

component=client component=connector/flink

apache/fluss#742 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Reorganize the update mechanisms for logStartOffset, LocalStartOffset, and remoteLogStartOffset Open

component=log

apache/fluss#744 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
ReplicaManager caches the projectionInfo to reduce the resource consumption for building projections. Open

apache/fluss#748 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Introduce OffsetsForLeaderEpochRequest/Response Open

component=log

apache/fluss#750 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
RPC GetFileSystemSecurityToken supports grant table-level STS token Open

apache/fluss#752 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Unstable test ReplicaFetcherThreadTest#testFollowerHighWatermarkHigherThanOrEqualToLeader Open

apache/fluss#760 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
ReplicaStateMachine should consider ReplicaDeletionStarted/ReplicaDeletionSuccessful as a valid previous state Open

apache/fluss#764 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
TableBucketStateMachine should consider NonExistentBucket as a valid previous state Open

apache/fluss#765 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Server should handle the case of table_id inconsistent between table node and partition node Open

apache/fluss#767 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Response return in order needs to be redesigned to ensure performance Open

apache/fluss#771 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Introduce jitter for auto create partition Open

apache/fluss#775 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
DelayedFetchLogOperation will not be trigged to complete when replica number set to 1 Open

apache/fluss#777 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Introduce a consistent and persistent leaderEpoch cache across different tabletServer Open

component=log

apache/fluss#789 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[File system] Enable clients access the Google File System through the FileSystem security token receiver API Open

apache/fluss#801 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Umbrella][Feature] Support for complex data types Open

apache/fluss#816 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support for GenericArray && InternalArray interface Open

apache/fluss#817 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support for GenericMap && InternalMap interface Open

apache/fluss#819 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Test is unstable because waitUntilPartitions timeout Open

apache/fluss#832 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
"fluss-client" artifact shouldn't bundle dependencies Open

apache/fluss#841 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add json parsing options in JsonStringDeserializationSchema Open

apache/fluss#851 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Umbrella] Subissue Improve protogen.* test coverage Open

component=test

apache/fluss#881 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella] Subissue Improve memory.* test coverage Open

component=test

apache/fluss#882 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella] Subissue Improve utils.* test coverage Open

component=test

apache/fluss#883 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella] Subissue Improve row.* test coverage Open

component=test

apache/fluss#885 · 5 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Umbrella] Subissue Improve table.* test coverage Open

component=test

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

apache/fluss

Get new issues in your inbox