apache/fluss

View on GitHub

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

Stars: 2.2k
Forks: 627
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 18, 2026
Latest indexed: Sep 14, 2026
Contributing guide: No contributing guide
Code of conduct: Code of conduct
Beginner labels: good first issue

Open All

618 open issues indexed

[server] Add coordinator metrics for rebalance Open

apache/fluss#4055 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kv] Improve point lookup concurrency with KV writes Open

apache/fluss#4057 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] Flink Catalog loses nested NOT NULL constraints in complex types Open

apache/fluss#4062 · 5 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[kv] Batch old-value lookups in the KV write path Open

apache/fluss#4063 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rust] Add property overlays for rust client Config Open

apache/fluss#4064 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/iceberg] Support multi-bucket-key tables Open

apache/fluss#4069 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[build] fluss-fs-s3 uber-jar bundles 1,114 unshaded jackson classes that can shadow downstream jackson Open

apache/fluss#4072 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Introduce client.writer.delivery-timeout to Fluss Write Client Open

apache/fluss#4075 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[FIP-49][gateway] Add HTTP-layer REST authentication and protocol-neutral principals Open

apache/fluss#4081 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rebalance] Support preferred leader election goal Open

apache/fluss#4086 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] Support bounded write delivery (delivery timeout) Open

apache/fluss#4087 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[helm] Support advertised listeners for out-of-cluster clients Open

apache/fluss#4092 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] Flink add_acl examples in procedures.md do not match the implementation Open

apache/fluss#4099 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[gateway] Share dial failures with current waiters Open

apache/fluss#4101 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[helm] First-class coordinator HA: readiness gate valid for standby coordinators Open

apache/fluss#4105 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[helm] Support multi-disk data.dirs in the tablet StatefulSet Open

apache/fluss#4106 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[build] fluss-filesystems uber-jars ship unshaded jackson + guava that can shadow downstream dependencies Open

apache/fluss#4116 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] Expose all coordinator servers (leader and standbys) via the client API Open

apache/fluss#4117 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Support sequence groups in default and agg merge engine Open

apache/fluss#4129 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[KV] Bump RocksDB version to 11.8.1 Open

apache/fluss#4132 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test Flink22OrphanFilesCleanITCase.mixedOrphanAndActiveFilesInSameBucket Open

apache/fluss#4137 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[metrics] Histogram samples never age out, leaving stale percentiles on low-frequency metrics Open

apache/fluss#4139 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[build] Unshaded commons, netty and jackson leak from the client, connector, lake and filesystem uber-jars Open

apache/fluss#4143 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Coordinator can advertise a leader before the target tablet server admits the replica, causing NotLeaderOrFollowerException to recur for minutes after a large-table restart Open

apache/fluss#4149 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[FIP-28] Support incremental cleanup of historical KV state Open

component=server priority=normal

apache/fluss#4159 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[FIP-28] Refresh server partition status for historical write routing Open

component=client priority=normal

apache/fluss#4161 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[FIP-28] Smoothly reroute writes with in-flight requests after partition retirement Open

apache/fluss#4166 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test HistoricalPartitionLookupITCase.testLookupExpiredPartitionFromPaimon Open

apache/fluss#4176 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test ReplicaManagerTest.testTaggedLookupAndPrefixResultsUseRpcSlices Open

apache/fluss#4177 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella] Kafka Protocols Compatibility - Basic Produce Open

apache/fluss#4185 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[trino] Add native read-only Trino connector Open

apache/fluss#4197 · 10 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test ReplicaManagerTest.testLookupWithInsertIfNotExistsAutoIncrement Open

apache/fluss#4211 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Gateway] DECIMAL decoder rejects exponent notation Open

apache/fluss#4214 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella] Support production-ready bulk loading for primary-key tables Open

apache/fluss#4222 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[Server] Support importing completed KV snapshots Open

apache/fluss#4223 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Server] Add the server-side primary-key table bulk-load protocol Open

apache/fluss#4224 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Client] Add the primary-key table bulk-load client SDK Open

apache/fluss#4225 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Client] [Server] Add temporary write authorization for bulk-load sessions Open

apache/fluss#4226 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Flink] Support Flink batch insert into Fluss primary-key tables Open

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

apache/fluss#4233 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/iceberg] Support custom Iceberg lake table path Open

apache/fluss#4251 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] NotLeaderOrFollowerException persists when a stale TabletServer endpoint is reused Open

apache/fluss#4256 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kafka] Add request and transport framework Open

apache/fluss#4264 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kafka] Implement registry-backed ApiVersions API Open

apache/fluss#4265 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kafka] Implement Metadata API for pre-created Fluss tables Open

apache/fluss#4266 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Server] Clean leader reassignment can leave divergent WAL in an ISR replica Open

apache/fluss#4269 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rust] get_table returns InvalidTableException for a nonexistent table Open

apache/fluss#4270 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[kafka] Define DDL table mapping for Kafka compatibility Open

apache/fluss#4275 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] C++ client: provide async/callback API for write result instead of blocking Wait() Open

apache/fluss#4276 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] Add retry backoff when disk protection rejects writes Open

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

apache/fluss

Get new issues in your inbox