12 Pull requests merged by 9 people

• [hotfix] Don't print waiting info in FlinkRowAssertionsUtils.waitForN…

  #1650 merged Sep 5, 2025

• [lake] Avoid cast to KeyValueFileStore to get keyComparator in paimon

  #1649 merged Sep 5, 2025

• Union read support primary key table in streaming mode

  #1613 merged Sep 5, 2025

• [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable()

  #1638 merged Sep 5, 2025

• [client] Change the default value of 'netty.client.num-network-threads' to 3 to avoid netty channel congestion

  #1642 merged Sep 4, 2025

• [docs] Add FETCH_LOG monitoring metrics to Fluss monitor-metrics doc

  #1611 merged Sep 4, 2025

• [test/flink] Collect flink rows should always be with timeout

  #1622 merged Sep 4, 2025

• [docs][Fluss-1483] Fix distributed mode guide, cannot set local path

  #1484 merged Sep 3, 2025

• Pk tables blog post

  #1609 merged Sep 3, 2025

• [connector] support spark catalog

  #258 merged Aug 31, 2025

• [connector] Support spark catalog and introduce some basic classes

  #544 merged Aug 31, 2025

• [hotfix] Fix README

  #1623 merged Aug 31, 2025

10 Pull requests opened by 9 people

• [server] feat: support alter table properties

  #1625 opened Aug 30, 2025

• [docs] Update security documentation for clarity and detail

  #1626 opened Aug 30, 2025

• [docs] Refactor Java Client documentation for clarity and structure

  #1628 opened Aug 31, 2025

• [server] Support rebalance for PrimaryKey Table

  #1630 opened Sep 3, 2025

• [kv] Implement tableDescriptor based RocksDB conf - WIP

  #1631 opened Sep 3, 2025

• [flink] Fluss enumerator partition discovery in fixed delay rather than fixed rate.

  #1633 opened Sep 3, 2025

• [spark] Support spark catalog and introduce some basic classes

  #1636 opened Sep 3, 2025

• [server] Fix ReplicaFetcherThread keeps throwing OutOfOrderSequenceException because of writer id expire

  #1639 opened Sep 3, 2025

• [lake/iceberg] Add iceberg documents for lakehouse support in fluss

  #1640 opened Sep 3, 2025

• [log] Support filter pushdown for log tables

  #1644 opened Sep 4, 2025

10 Issues closed by 4 people

• Don't cast to KeyValueFileStore to get keyComparator in paimon

  #1648 closed Sep 5, 2025

• Union read support primary key table in streaming mode

  #1437 closed Sep 5, 2025

• Improve TableAlreadyExistException message for LakeCatalog.createTable()

  #1637 closed Sep 5, 2025

• org.apache.paimon.privilege.PrivilegedFileStore cannot be cast to org.apache.paimon.KeyValueFileStore

  #1635 closed Sep 5, 2025

• [lake] table.datalake.format only appears when the table has lake enabled

  #1646 closed Sep 5, 2025

• LogScanner's consumption latency keeps increasing during cluster upgrades

  #1641 closed Sep 4, 2025

• Add FETCH_LOG monitoring metrics to Fluss monitor-metrics documentation

  #1610 closed Sep 4, 2025

• Collect flink rows should always be with timeout

  #1621 closed Sep 4, 2025

• “CREATE TABLE IF NOT EXISTS ” do not work

  #1634 closed Sep 4, 2025

• "No such file or directory" When query table

  #1483 closed Sep 3, 2025

7 Issues opened by 7 people

• Iceberg support union read

  #1647 opened Sep 5, 2025

• Add restore test for streaming union read

  #1645 opened Sep 4, 2025

• why lookup join condition must include all primary keys of the dimension table

  #1643 opened Sep 4, 2025

• Fluss enumerator partition discovery in fixed delay rather than fixed rate.

  #1632 opened Sep 3, 2025

• [server] Drop table (partition) may fail when tablet server crashs

  #1629 opened Sep 1, 2025

• [fluss-client] Missing fluss-client JAR in Maven Central

  #1627 opened Aug 31, 2025

• ReplicaFetcherThread keeps throwing OutOfOrderSequenceException

  #1624 opened Aug 30, 2025

107 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• Support Compacted LogFormat

  #1605 commented on Sep 3, 2025 • 4 new comments

• [Filesystem] Support use Hadoop dependencies from environment variables HADOOP_CLASSPATH

  #1359 commented on Sep 4, 2025 • 3 new comments

• [flink]Support partition pushdown in Flink connector

  #420 commented on Sep 4, 2025 • 1 new comment

• [build] Add github labeler for pull request

  #1498 commented on Aug 31, 2025 • 0 new comments

• [server] handle uncaught exceptions in TabletServer during log recovery from residual data corresponding to already dropped tables

  #1487 commented on Aug 31, 2025 • 0 new comments

• [kv] TabletSever must handle inconsistency or broken snapshot scenarios.

  #1482 commented on Sep 3, 2025 • 0 new comments

• Use background mode for delete partition assignment in zk

  #1477 commented on Aug 31, 2025 • 0 new comments

• [kv] coordinator must handle inconsistency or broken snapshot scenarios

  #1470 commented on Aug 31, 2025 • 0 new comments

• [coordinator] coordinator report event enqueue rate and event process time labeled by event_type

  #1466 commented on Aug 31, 2025 • 0 new comments

• [server] server process metadata request in async mode

  #1463 commented on Aug 31, 2025 • 0 new comments

• [server] Support generate and execute reblance plan

  #1452 commented on Sep 4, 2025 • 0 new comments

• [server] Introduce new fields 'deleted_marker' in UpdateMetadata RPC

  #1450 commented on Aug 31, 2025 • 0 new comments

• [client] Expose fluss security properties to catalog's optional options.

  #1429 commented on Aug 31, 2025 • 0 new comments

• Change the implementation of Admin#getServerNodes() to support carrying ServerTag

  #1410 commented on Aug 31, 2025 • 0 new comments

• [rpc] Implement max inflight requests limit per connection

  #1408 commented on Aug 31, 2025 • 0 new comments

• [Client] Add RowConverterUtils helper

  #1404 commented on Aug 31, 2025 • 0 new comments

• [server] Coordinator Server Supports High-Available

  #1401 commented on Sep 2, 2025 • 0 new comments

• [server] Support AddServerTag and RemoveServerTag

  #1400 commented on Sep 3, 2025 • 0 new comments

• [server] improve performance of Coordinator Server initCoordinatorContext()

  #1381 commented on Aug 31, 2025 • 0 new comments

• [server] Introduce new rebalance API

  #1380 commented on Sep 3, 2025 • 0 new comments

• [kv] commit kv snapshot to zk asynchronously, not blocking coordinato…

  #1375 commented on Sep 4, 2025 • 0 new comments

• [Feature] Row Type Foundation

  #1370 commented on Aug 31, 2025 • 0 new comments

• [kv] support shared block cache for kv tablets

  #1365 commented on Aug 31, 2025 • 0 new comments

• [hotfix] Fix unstable testLakeTieringHeartBeat test

  #1357 commented on Aug 31, 2025 • 0 new comments

• [kv] support export key metrics for rocksdb

  #1355 commented on Aug 31, 2025 • 0 new comments

• [docker] Add Fluss local-cluster docker file

  #1285 commented on Aug 31, 2025 • 0 new comments

• [bug fix] Avoid infinite recursion in RecordsFieldFinder

  #1282 commented on Aug 31, 2025 • 0 new comments

• [flink/ci] Add watchdog for flink timeout failure stack trace at 95 percent time completion

  #1280 commented on Aug 31, 2025 • 0 new comments

• Introduce BinaryRowData for row data encoding

  #1620 commented on Sep 3, 2025 • 0 new comments

• [hotfix] Enhance the log of rebuildWriterState

  #1618 commented on Aug 31, 2025 • 0 new comments

• [hotfix] Use 'writer' instead of 'producer' in log

  #1617 commented on Aug 31, 2025 • 0 new comments

• [proto] Support generate toString() method for the proto messages

  #1616 commented on Aug 31, 2025 • 0 new comments

• Throw Exception If catalog default database is not existed .

  #1608 commented on Sep 3, 2025 • 0 new comments

• [common] Support general DELETE statement on primary key table.

  #1597 commented on Aug 31, 2025 • 0 new comments

• [license] Update files headers license from Alibaba to Apache Software Foundation

  #1596 commented on Aug 31, 2025 • 0 new comments

• [docs] Fix typos and improve readability in maintanance page

  #1595 commented on Aug 31, 2025 • 0 new comments

• [lake/lance] add documentation for Lance connector

  #1587 commented on Aug 31, 2025 • 0 new comments

• [flink] Lake table getTable decouple with paimon

  #1586 commented on Aug 31, 2025 • 0 new comments

• [docs] Fix typos streaming lakehouse page

  #1581 commented on Aug 31, 2025 • 0 new comments

• [docs] Fix typos and enhance doc for better readability

  #1570 commented on Aug 31, 2025 • 0 new comments

• [FIP-12] add dynamic config to enable lakehouse.

  #1567 commented on Sep 3, 2025 • 0 new comments

• [server] Fluss Table Support Alter bucket

  #1554 commented on Sep 2, 2025 • 0 new comments

• [metrics] Adding Server-Level Storage Aggregation Metrics

  #1548 commented on Aug 31, 2025 • 0 new comments

• [rpc] Avoid NettyClient#getOrCreateConnection run to deadlock in JDK8

  #1546 commented on Aug 31, 2025 • 0 new comments

• [server] Servers with PERMANENT_OFFLINE and TEMPORARY_OFFLINE tag are no longer assigned replicas

  #1538 commented on Aug 31, 2025 • 0 new comments

• [metric] metrics aggregation

  #1531 commented on Aug 31, 2025 • 0 new comments

• [filesystems/hdfs] Publish Bundled HDFS Artifact

  #1522 commented on Aug 31, 2025 • 0 new comments

• Fix Download Page fluss-fs-hadoop Link

  #1516 commented on Aug 31, 2025 • 0 new comments

• [client-tool] provide basic fluss Command Line framework based on Pic…

  #1510 commented on Aug 31, 2025 • 0 new comments

• [server] feat: support alter table properties

  #1509 commented on Aug 31, 2025 • 0 new comments

• [server] Push partition filtering to the server-side to reduce network bandwidth usage

  #1507 commented on Aug 31, 2025 • 0 new comments

• [filesystem] Add TencentCloud COS integration

  #1506 commented on Aug 31, 2025 • 0 new comments

• Add configuration options to control table creation restrictions

  #1503 commented on Aug 31, 2025 • 0 new comments

• [server] Remove TableInfo in UpdateMetadata

  #1499 commented on Aug 31, 2025 • 0 new comments

• [hotfix] Add @Override on CoordinatorService.adjustIsr

  #1276 commented on Aug 31, 2025 • 0 new comments

• [server] Store the relative path instead of absolute path in KvFileHandle

  #684 commented on Aug 31, 2025 • 0 new comments

• 646: Increase coverage for FlinkCounter, FlinkGauge, FlinkHistogram, FlinkHistogramStatistics, FlinkMeter

  #649 commented on Aug 31, 2025 • 0 new comments

• Include observability quickstart files in binary distribution

  #615 commented on Aug 31, 2025 • 0 new comments

• [connector/flink] Read support for fluss primary key table changelogs system table/ cdc events

  #510 commented on Aug 31, 2025 • 0 new comments

• [client] Introduce AdminApiDriver for workflows which lookup broker first then send request.

  #479 commented on Aug 31, 2025 • 0 new comments

• [client] Add retry when get one available tablet serverNode fails

  #426 commented on Aug 31, 2025 • 0 new comments

• [test] Enable FlussTableITCase#testAppendWithSmallBuffer

  #364 commented on Aug 31, 2025 • 0 new comments

• [client] Add timeout for inflight request to netty client.

  #300 commented on Aug 31, 2025 • 0 new comments

• [Common] Rename DefaultLogRecordBatch to MemoryLogRecordBatch

  #235 commented on Aug 31, 2025 • 0 new comments

• [connector/flink] Report pendingRecords.

  #157 commented on Aug 31, 2025 • 0 new comments

• Allow project to build with Java 17 and 21

  #114 commented on Aug 31, 2025 • 0 new comments

• [server] Support alter table to update properties and custom properties

  #101 commented on Aug 31, 2025 • 0 new comments

• [core] Optimize early verification of table types.

  #97 commented on Aug 31, 2025 • 0 new comments

• [server] Add tests case for RemoteLogITCase

  #96 commented on Aug 31, 2025 • 0 new comments

• [connector] Fluss Connector support batch source.

  #88 commented on Aug 31, 2025 • 0 new comments

• [server] Log support compacted row format

  #85 commented on Aug 31, 2025 • 0 new comments

• [core] Support rename table in flink catalog.

  #77 commented on Aug 31, 2025 • 0 new comments

• [chore][metric] change log print level for meeting metric already registered

  #60 commented on Aug 31, 2025 • 0 new comments

• [chore][rpc] change log print level for netty client when received all_idle event

  #59 commented on Aug 31, 2025 • 0 new comments

• Support Iceberg as Lakehouse Storage

  #452 commented on Sep 5, 2025 • 0 new comments

• [KV] Support Full Scan on PK Table

  #1600 commented on Sep 4, 2025 • 0 new comments

• Throw Exception If catalog default database is not existed.

  #1607 commented on Sep 3, 2025 • 0 new comments

• [KV] Support Customized KV Options When Creating Primary Key Tables

  #1326 commented on Sep 3, 2025 • 0 new comments

• [Feature] Introduce BufferWriteManager in rocksdb for controllable memory consume

  #69 commented on Sep 1, 2025 • 0 new comments

• Implement obtainSecurityToken for google filesystem

  #993 commented on Aug 31, 2025 • 0 new comments

• [Feature] Support spark catalog(base spark 3.3.3)

  #228 commented on Aug 31, 2025 • 0 new comments

• [docs] OpenTelemetry Metrics Exporter Docs and Quickstart Guide

  #1270 commented on Aug 31, 2025 • 0 new comments

• bugfix: create lake table support if not exists

  #1266 commented on Aug 31, 2025 • 0 new comments

• Issue 489 parition key more types apache

  #1264 commented on Aug 31, 2025 • 0 new comments

• [client] Reset writer id when out of order exception instead of throw exception directly

  #1261 commented on Aug 31, 2025 • 0 new comments

• bugfix: fix exception type during reading from removed partitions

  #1257 commented on Sep 4, 2025 • 0 new comments

• [file system] Configurable token delegation process to enable other authentication methods in S3 credential provider chain

  #1245 commented on Aug 31, 2025 • 0 new comments

• [examples] A module for fluss examples

  #1230 commented on Aug 31, 2025 • 0 new comments

• [server] Introduce plugin.classloader.parent-first-patterns.additional configuration

  #1222 commented on Aug 31, 2025 • 0 new comments

• [server][auth] Support kerberos authentication

  #1207 commented on Aug 31, 2025 • 0 new comments

• [flink] support partial updates via column names

  #1198 commented on Aug 31, 2025 • 0 new comments

• [Metrics] Add OpenTelemetry metrics exporter

  #1188 commented on Aug 31, 2025 • 0 new comments

• [feature] Support alter database comment and custom properties

  #1172 commented on Aug 31, 2025 • 0 new comments

• [test] TableChangeWatcherTest.testTableChanges is not stable

  #1171 commented on Aug 31, 2025 • 0 new comments

• [docs] Add docs for Google Cloud Storage (GCS) Filesystem

  #1170 commented on Aug 31, 2025 • 0 new comments

• [Server] TabletServer support controlled shutdown

  #1159 commented on Aug 31, 2025 • 0 new comments

• [client-tool] provide basic fluss Command Line framework

  #1114 commented on Aug 31, 2025 • 0 new comments

• Add log file rolling for maven test output

  #1019 commented on Aug 31, 2025 • 0 new comments

• [hotfix] Remove residual tablePath in coordinatoContext when drop a partition table without any partition

  #987 commented on Aug 31, 2025 • 0 new comments

• [test] improve test coverage for com.alibaba.fluss.record

  #899 commented on Aug 31, 2025 • 0 new comments

• [Docs] Update Monitoring Metrics Page

  #896 commented on Aug 31, 2025 • 0 new comments

• [flink] FlinkCatalog supports create and drop materialized table

  #862 commented on Aug 31, 2025 • 0 new comments

• [log] Introduce OffsetForLeaderEpoch Request/Response

  #788 commented on Aug 31, 2025 • 0 new comments

• [spark]Support Spark streaming read

  #783 commented on Aug 31, 2025 • 0 new comments

• Bump LogRecordBatch's CURRENT_LOG_MAGIC_VALUE to V1 to support leaderEpoch

  #778 commented on Aug 31, 2025 • 0 new comments

• [WIP][File system] Allow to obtain temporary credentials via STS `AssumeRoleWithWebIdentity` in S3

  #689 commented on Aug 31, 2025 • 0 new comments

• [client] Introduce batchDeliveryTimeout in client to expire batches that have been stuck for a long time

  #686 commented on Aug 31, 2025 • 0 new comments