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

Optimize client bucket-level metrics Open

apache/fluss#3826 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[security] Support group-based ACL authorization for authenticated identities Open

apache/fluss#3829 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Support custom Paimon lake table paths Open

apache/fluss#3832 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Support time-based log segment rolling (segment.ms) Open

apache/fluss#3833 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support impersonation via SASL/PLAIN authorization id Open

apache/fluss#3837 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rust] Filter pushdown Open

apache/fluss#3843 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Add a local development kit for contributors Open

apache/fluss#3850 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rust] Umbrella: fluss-rust client support required by the Fluss REST Gateway Open

apache/fluss#3854 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test Flink118TableSourceBatchITCase.testLogTableBatchScanSupportsNonFullStartupMode Open

apache/fluss#3856 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support listener-specific SASL enabled mechanisms Open

apache/fluss#3858 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Improvement] Make timed-out rebalance tasks recoverable Open

apache/fluss#3859 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[rust] Support bounded write delivery (delivery timeout) Open

apache/fluss#3861 · 7 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[filesystem] Add JuiceFS filesystem support Open

apache/fluss#3866 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[server] Improve rebalance stability and scalability Open

apache/fluss#3867 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Store large rebalance plans outside ZooKeeper Open

apache/fluss#3868 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Apply the planned leader during replica reassignment Open

apache/fluss#3869 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[server] Balance leaders within each table Open

apache/fluss#3871 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[test] Unstable test Flink118TableSourceBatchITCase.testCountPushDownForLogTable Open

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

apache/fluss#3878 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test RemoteLogScannerITCase.testPartitionTableFetchFromRemote Open

apache/fluss#3879 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[ci] Maven Shade Plugin occasionally fails with NullPointerException during parallel builds Open

apache/fluss#3880 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support SASL/SCRAM-SHA-256 authentication for Fluss RPC Open

apache/fluss#3881 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Improvement] Support configurable unclean election for offline bucket recovery Open

apache/fluss#3894 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[FIP-27] Support clean and legacy Hudi lake table schemas Open

apache/fluss#3904 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[filesystem] Evaluate DefaultCredentialsProvider for S3 authentication Open

apache/fluss#3916 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Tiering] Trigger job failover when coordinator epoch changes Open

apache/fluss#3921 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
readiness-check should derive client authentication from the local server configuration Open

apache/fluss#3926 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Streaming hybrid lake reads may skip splits and rescan after recovery Open

apache/fluss#3931 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[CI] Move Spark Scala 2.13 tests from PR CI to nightly Open

apache/fluss#3936 · 3 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[Improvement] Share Paimon historical lookup disk cache across tables Open

apache/fluss#3955 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Umbrella][FIP-49] Implement the Fluss Gateway REST API Open

apache/fluss#3957 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rust] Support SASL/PLAIN authorization identity(act as) Open

apache/fluss#3959 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[rust] Support writing records to multiple tables Open

apache/fluss#3961 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add completion timestamp and historical listing to RebalanceProgress Open

apache/fluss#3965 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Expose a human-readable Fluss server version via the client API Open

apache/fluss#3966 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Flink] Flink catalog fails on duplicate index columns Open

apache/fluss#3975 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[helm] `render-jaas-config` init container has no resources, so SASL-enabled pods can never reach Guaranteed QoS Open

apache/fluss#3979 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] COS STS default policy uses an invalid wildcard owner UID Open

apache/fluss#3983 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[flink] BETWEEN predicate fails at runtime after pushdown: literal extraction missing in PredicateConverter Open

priority=critical

apache/fluss#4000 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] Expose Arrow changelog batches for primary-key tables Open

apache/fluss#4005 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] ZooKeeper Removal and Embedded Raft Metadata Backend Open

apache/fluss#4014 · 0 comments · 4 reactions · 0 assignees · Indexed Sep 14, 2026
Add Jepsen correctness tests Open

apache/fluss#4015 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] ReplicaTest is flaky due to stale gauges in shared test metric groups Open

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

apache/fluss#4025 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Support table-level minimum in-sync replicas config Open

apache/fluss#4026 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] Admin write operations do not recover after coordinator leader failover Open

priority=critical

apache/fluss#4027 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Lake][Paimon] Tiering fails with endless retries when the Paimon lake table schema is wider than the Fluss record (externally evolved schema) Open

apache/fluss#4038 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Client] Add client.lookup.max-inflight-requests-per-bucket to restrict lookup requests per server Open

apache/fluss#4043 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[build] Shaded fat-JARs (fluss-client, fluss-flink, etc.) leak shaded module-info.class, breaking JPMS modular consumption Open

apache/fluss#4045 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/iceberg] Implement SupportsRecordBatchWrite for IcebergLakeWriter Open

apache/fluss#4047 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026

apache/fluss

Get new issues in your inbox