apache/fluss

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

Fix NoSuchElementException that occurs when recovering log segments Open

apache/fluss#2943 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test FlussSinkITCase.testPartialUpdateWithTwoWriters Open

apache/fluss#2954 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support reading tiering source data as Arrow RecordBatch Open

apache/fluss#2962 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support direct Arrow RecordBatch to Parquet conversion Open

apache/fluss#2963 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Fix OutOfBoundException in writeChangeType when the number of records is large Open

apache/fluss#2967 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test CoordinatorEventProcessorTest.testDoBucketReassignment Open

apache/fluss#2975 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test CommitRemoteLogManifestITCase.testDeleteOutOfSyncReplicaLogAfterCommit Open

apache/fluss#2982 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Add spark tiering service Open

apache/fluss#2985 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test RemoteLogScannerITCase.testScanFromRemoteAndProject Open

apache/fluss#2992 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test Flink120ProcedureITCase.testDropKvSnapshotLeaseProcedure Open

apache/fluss#2993 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test RemoteLogITCase.remoteLogMiscTest Open

apache/fluss#2994 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client][server] Support dynamically modifying table.auto-increment.cache-size via ALTER TABLE Open

apache/fluss#3005 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[client] Implement adaptive fetch rate control for LogScanner to reduce overhead on partitioned tables Open

apache/fluss#3006 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[fluss-server] Fix replicasOnOffline deadlock in addFetcherForReplicas Open

apache/fluss#3011 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test TableManagerITCase.testSchemaEvolution Open

apache/fluss#3016 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test FlussAdminITCase.testKvSnapshotLeaseForLogTable Open

apache/fluss#3020 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] Fix website broken anchors Open

good first issue

apache/fluss#3038 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Support delete records for pk table Open

apache/fluss#3039 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake][iceberg] Iceberg does not support union read for primary key table Open

apache/fluss#3048 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support secondary index on `user_id` / (`user_id`, `order_date`) for detail tables used by Flink SQL Open

apache/fluss#3064 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add fluss-microbench module: YAML-driven performance testing framework Open

apache/fluss#3080 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test RemoteLogITCase.testRemoteLogTTLWithDynamicLakeToggle Open

apache/fluss#3083 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Flink log table consumer threw an out-of-range offset exception Open

apache/fluss#3084 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[flink] Skip emitting update events when only non-projected columns are modified in source connector Open

component=connector/flink

apache/fluss#3095 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[test] Unstable test IcebergRewriteITCase.testPkTableCompaction Open

apache/fluss#3100 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test FlussAdminITCase.testDynamicConfigs Open

apache/fluss#3127 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature]Support managing existing Apache Iceberg tables with Fluss Open

apache/fluss#3138 · 0 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[test] Unstable test RemoteLogDownloaderTest.testPrefetchNum Open

apache/fluss#3145 · 4 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
Introduce generic secondary index metadata foundation Open

apache/fluss#3155 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] Move the manual JAR + Docker Compose Flink setup into Engine Flink getting started Open

apache/fluss#3162 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[docs] Plan a fluss-quickstart-spark image for Spark Quickstart Open

apache/fluss#3163 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[tiering] Coordinator Should Push Lake Config to Tiering Service via Heartbeat RPC Open

apache/fluss#3170 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
PK table messagesIn/bytesIn metrics double-counted due to CDC log Open

apache/fluss#3176 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Add documentation for FIP (Flink Improvement Proposal) contribution guide Open

component=website good first issue

apache/fluss#3179 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Support configurable time partition format for auto-partitioned tables Open

apache/fluss#3191 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[server] local-cluster.sh starts successfully but processes fail silently when JAVA_HOME is misconfigured Open

apache/fluss#3192 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Spark] Add set_cluster_configs and reset_cluster_configs procedures for Spark connector Open

apache/fluss#3203 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[spark] Umbrella issue for scan optimization Open

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

apache/fluss#3218 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Limit scan for log table with complex type will thrown exception. Open

apache/fluss#3219 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Skip bucket recovery for non-existent partitions Open

apache/fluss#3223 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Recovery failure when the tablet server shuts down due to 'No space left on device' Open

apache/fluss#3224 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Possible OutOfRangeException when reading the stream log table after resuming from a long interruption Open

apache/fluss#3228 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Streaming union read from the lake and Fluss log table using a specified offset timestamp Open

apache/fluss#3230 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella] Umbrella issue for System Tables Open

apache/fluss#3235 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Add authorization to Snapshot Read Operations (getLatestKvSnapshots, getKvSnapshotMetadata, getLatestLakeSnapshot) Open

apache/fluss#3248 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Add authorization to Replication Control RPCs (notifyLeaderAndIsr, updateMetadata, stopReplica, adjustIsr) Open

apache/fluss#3249 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Add authorization to Snapshot Management RPCs (commitKvSnapshot, notifyKvSnapshotOffset, commitLakeTableSnapshot, notifyLakeTableOffset) Open

apache/fluss#3250 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[server] Add authorization to Remote Log & Tiering RPCs (commitRemoteLogManifest, notifyRemoteLogOffsets, lakeTieringHeartbeat) Open

apache/fluss#3251 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
FIP-24: Support tiering Fluss data to Hudi Open

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

A short digest of beginner-friendly GitHub issues.