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

628 issues indexed so far

Support ReplicaFetcherThread fetch log async Open

component=server

apache/fluss#11 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support batch read table without datalake enabled Open

component=connector/flink

apache/fluss#40 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Log scanner should support fetch the logs tiered into lake Open

component=client

apache/fluss#41 · 1 comment · 1 reaction · 1 assignee · Indexed Sep 14, 2026
[Feature] Introduce BufferWriteManager in rocksdb for controllable memory consume Open

component=server

apache/fluss#69 · 2 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[Feature] Control the background job thread nums of rocksdb Open

component=server

apache/fluss#70 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Fluss client support to pin/unpin snapshot Open

component=client component=server

apache/fluss#71 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support rename table in flink catalog Open

apache/fluss#76 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Docs] Add a FAQ page Open

component=docs

apache/fluss#103 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Fluss lake dynamic table supports pluggable Open

apache/fluss#106 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Feature] Enable Fluss to run in github-hosted runners Open

component=test

apache/fluss#109 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Test] When run IT in github-hosted runner such like ReplicaFetcherITCase, KvSnapshotITCase , NetworkException will be thrown: Open

component=test

apache/fluss#110 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
`FlussTableITCase.testAppendWithSmallBuffer` will hang forever Open

apache/fluss#116 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Make bucketAssigner for lake table pluggable Open

apache/fluss#124 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Reuse GatewayClientProxy and avoid re-creation Open

apache/fluss#127 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Test] TableManagerITCase.testPartitionedTableManagement is not stable Open

component=test good first issue

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

component=common

apache/fluss#168 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support for Map data type Open

component=common

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

component=common

apache/fluss#170 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[metrics] OpenTelemetry metric reporter Open

component=metrics

apache/fluss#181 · 5 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Feature] Add fine-grained table synchronization for lakehouse compaction service. Open

component=lake

apache/fluss#186 · 4 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Bug] Tests are blocked on "FlussClusterExtension#waitUtilAllGatewayHasSameMetadata" Open

apache/fluss#194 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Add kv perf module Open

apache/fluss#198 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Test] Unstable test case FlussTableITCase#testPutAndLookup Open

component=test good first issue

apache/fluss#200 · 3 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Feature] Upgrade programing language to Java 17 Open

component=build

apache/fluss#203 · 3 comments · 3 reactions · 0 assignees · Indexed Sep 14, 2026
[Test] ReplicaFetcherITCase.testProduceLogNeedAck is not stable Open

component=test good first issue

apache/fluss#206 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Test] FlinkUnionReadPrimaryKeyTableITCase.testPrimaryKeyTable is not stable Open

component=test good first issue priority=critical

apache/fluss#207 · 6 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Test] FlussDatabaseSyncSourceITCase.testDatabaseSyc is not stable Open

component=test good first issue

apache/fluss#208 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Test] StopReplicaITCase.testStopReplica is unstable Open

component=test good first issue

apache/fluss#209 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Introduce Merge Engines for Primary-Key Table Open

component=kv

apache/fluss#212 · 6 comments · 2 reactions · 0 assignees · Indexed Sep 14, 2026
[Test] FlinkCatalogITCase.testCreateNoPkTable is unstable Open

component=test good first issue

apache/fluss#215 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Support specific branch to sync to paimon Open

component=lake

apache/fluss#269 · 3 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Feature] Support fluss on k8s deployment, combined with flimk operator for use Open

apache/fluss#273 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] client request need timeout Open

apache/fluss#279 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Feature] Add itcase to test restoring for savepoint state. Open

good first issue

apache/fluss#280 · 10 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Bug] New Partiions created will cause Flink job failover when partition discovery is enabled while scanning Open

component=connector/flink

apache/fluss#288 · 6 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Feature] Command Line tool support Open

component=CLI

apache/fluss#298 · 23 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Bug] The time out for UpdateMetadata request is too short to cause job failover Open

component=client

apache/fluss#311 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Bug] Memory was leaked by query when close sender before send WriteBatch. Open

apache/fluss#321 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Feature] Fluss table support rescale Open

component=server

apache/fluss#327 · 5 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Support alter table config while adding partition name prefix for auto partition table Open

apache/fluss#380 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Rename KvManager and LogManager into KvStore and LogStore Open

component=server

apache/fluss#390 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
TieringService support convert arrow to parquet directly Open

component=lake/common

apache/fluss#437 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Tiering Service supports Self-termination via heartbeat Open

component=lake/tiering-flink

apache/fluss#441 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Replace paimon-flink dependency with fluss-lake-format-paimon dependency Open

component=connector/flink

apache/fluss#444 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Implement Hudi writer related interface based on POC code refinements Open

component=lake/hudi

apache/fluss#453 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Test] FlinkTableSinkITCase.testDeleteAndUpdateStmtOnPkTable is unstable Open

component=test good first issue

apache/fluss#455 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Test] MetadataUpdateITCase is unstable Open

component=test good first issue

apache/fluss#461 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Support retry mechanism when get available tablet server nodes failed Open

apache/fluss#480 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[client] Refactor metadata cache and async updating mechanism and retry mechanism in client side Open

component=client

apache/fluss#483 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Support Kerberos Authentication Open

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

apache/fluss

Get new issues in your inbox