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

[Umbrella] Subissue Improve record.* test coverage Open

component=test

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

component=test

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

component=test

apache/fluss#889 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Unstable test FlussAdminITCase.testGetKvSnapshot Open

apache/fluss#891 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Bump Paimon version from 1.0.1 to 1.1.1 Open

apache/fluss#895 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Drop a partitionTable without creating any partition will result in residual tablePath in coordinatoContext Open

component=server

apache/fluss#898 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Implement Delta writer related interface based on POC code refinements Open

apache/fluss#967 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Introduce new fields 'delete_table' and 'delete_partition' in UpdateMetadata RPC Open

component=server

apache/fluss#981 · 7 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Remove TableInfo from server MetadataCache Open

component=server

apache/fluss#982 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Some update metadata behavior can be sent by NotifyLeaderAndIsrRequest to reduce request number Open

apache/fluss#983 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Implement obtainSecurityToken for google filesystem Open

apache/fluss#993 · 7 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Not to change zk node for the partition/table to be deleted when replica is offline Open

apache/fluss#1001 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add log file rolling for maven test output Open

component=test good first issue

apache/fluss#1006 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Implement table sub command line tool Open

apache/fluss#1012 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Introduce Command Line tool framework Open

apache/fluss#1013 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Implement cluster sub command line tool Open

apache/fluss#1014 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add command line tool related script. Open

apache/fluss#1015 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Implement produce sub command line tool Open

apache/fluss#1016 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Implement consume sub command line tool Open

apache/fluss#1017 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Test CoordinatorEventProcessorTest.testCreateAndDropTable is not stable Open

component=test good first issue

apache/fluss#1026 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Test KvSnapshotITCase.testKvSnapshotAndDelete is unstable Open

component=test good first issue

apache/fluss#1027 · 9 comments · 1 reaction · 1 assignee · Indexed Sep 14, 2026
Print and upload stacktraces before test is timeout Open

apache/fluss#1031 · 3 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
When read from multi-partition table, the flink job currentEmitEventTimeLag is always high Open

priority=critical

apache/fluss#1037 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add docs for `advertised.listeners` with docker examples Open

apache/fluss#1039 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Release buffer redundantly in ServerHandler Open

priority=critical

apache/fluss#1044 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Remove inflightResponses in server when connection is inactive. Open

apache/fluss#1045 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Unstable test RemoteLogITCase.remoteLogMiscTest Open

apache/fluss#1110 · 3 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Support cluster throttling capabilities Open

component=server

apache/fluss#1145 · 3 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Add tabletServerEpoch to prevent offline tabletServer send requests to coordinator and wrongly handle Open

component=server

apache/fluss#1153 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella][Feature] Schema Evolution Support Open

apache/fluss#1154 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Umbrella] Add backward and forward compatibility E2E tests Open

apache/fluss#1161 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Writer throw OutOfOrderException when cluster upgrading Open

apache/fluss#1163 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[Build][Docs] Generate list of metrics in docs from source code Open

apache/fluss#1173 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] testReadKvTableWithEarliestAndTimestampScanStartupMode failed Open

apache/fluss#1194 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Add allin1 docker file Open

apache/fluss#1205 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[filesystem] Migrate to AWS SDK for Java v2 Open

component=filesystem

apache/fluss#1210 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[docs] Add docs for Google Cloud Storage (GCS) Filesystem Open

apache/fluss#1226 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[examples] Fluss examples module Open

apache/fluss#1231 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[examples] Data generation via datafaker Open

apache/fluss#1241 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[test] Flink120TableSourceITCase.testPrefixLookupPartitionedTable failed Open

priority=critical

apache/fluss#1252 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 14, 2026
Client receives unclear exception when accessing removed partitions Open

apache/fluss#1256 · 0 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[lake/lance]create Lake table support if not exists Open

apache/fluss#1260 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 14, 2026
[metrics] OpenTelemetry Metrics Exporter Implementation Open

component=metrics

apache/fluss#1268 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[docs] OpenTelemetry Metrics Exporter Docs and Quickstart Guide Open

component=docs

apache/fluss#1269 · 0 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[File system] Add TencentCloud COS integration Open

apache/fluss#1299 · 4 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
Paimon tiering best practise note in docs Open

component=docs good first issue

apache/fluss#1306 · 1 comment · 3 reactions · 1 assignee · Indexed Sep 14, 2026
NoClassDefFoundError: org/apache/hadoop/hdfs/HdfsConfiguration when using Paimon Lakehouse Open

priority=critical

apache/fluss#1314 · 13 comments · 1 reaction · 0 assignees · Indexed Sep 14, 2026
[KV] Bump the version of RocksDB to 10.2 Open

apache/fluss#1321 · 2 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[KV] Support Customized KV Options When Creating Primary Key Tables Open

apache/fluss#1326 · 4 comments · 0 reactions · 1 assignee · Indexed Sep 14, 2026
[Benchmark] Add E2E Benchmark Support for KV and LOG Workloads Open

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

apache/fluss

Get new issues in your inbox