DISCLAIMER: Apache Fluss (incubating) is an effort undergoing incubation at The Apache Software Foundation (ASF), sponsored by the Apache Incubator PMC.
Incubation is required of all newly accepted projects until a further review indicates that the infrastructure, communications, and decision making process have stabilized in a manner consistent with other successful ASF projects.
While incubation status is not necessarily a reflection of the completeness or stability of the code, it does indicate that the project has yet to be fully endorsed by the ASF.
Apache Fluss 0.9.1-incubating is a patch release on the 0.9 line containing bug fixes, Helm chart improvements, dependency upgrades, and documentation updates. It is fully compatible with 0.9.0 — no client or server changes are required to upgrade.
📥 Downloads: https://fluss.apache.org/downloads/#apache-fluss-091
🐛 Bug Fixes
Server / KV / Storage
- Fix Paimon
IOManagerleak inMergeTreeWritercausing/tmpdisk exhaustion during tiering (#3193) - Fix non-target columns not being nulled during partial update on first insert (#3157)
- Fix
OutOfBoundsExceptionin partial update / delete afterADD COLUMN(#3090) - Fix
ListDatabaseSummaryalways returning a table count of 0 or 1 (#2899) - Still remove server tag if the tablet server no longer exists (#2884)
- Validate non-primary-key tables for
KvSnapshotLeaseacquire / release APIs (#2736)
Client
- Fix early termination in
SortMergeReaderon changelog deletes (#3137) - Catch
Throwableto avoid silent failure on remote file download (#3136)
Flink Connector
- Fix
$changelogand$binlogvirtual tables failing with NPE on checkpoint completion (#2743) - Fix release of KV snapshot lease for log tables (#2721)
- Fix acquire of KV snapshot lease for legacy clusters (#2720)
Filesystem
- Propagate S3
path-style-accessconfig from server to client via delegation token (#3165)
✨ Improvements
- [flink] Push down lake filters for non-partitioned scans (#3181)
- [flink] Allow partial updates for the
AGGREGATIONmerge engine (#2905) - [server / netty] Introduce
netty.server.max-request-sizeto bound request size (#3108) - [filesystem / s3] Support the default AWS credential chain for S3 delegation (#3094)
- [filesystem / rustfs] Support
AssumeRoleSTS for RustFS (#2989)
⛵ Helm Chart
- Bump chart version to
0.9.1-incubating(#3205) - Add
existingSecretsupport for SASL credentials (#3189) - Support injecting environment variables and external secrets (#3184)
- Add pod annotations, labels, and PodDisruptionBudget support (#3185)
- Add scheduling primitives (nodeSelector / tolerations / affinity) (#3175)
- Backport general Helm chart improvements to
release-0.9(#3183) - Reintroduce the Quickstart image (#3166)
📦 Dependency Upgrades
- Bump
org.assertj:assertj-core3.23.1 → 3.27.7 (#3119) - Bump
org.apache.logging.log4j:log4j-1.2-api2.17.1 → 2.25.4 (#3118) - Bump
com.google.protobuf:protobuf-java2.5.0 → 3.25.5 (#3112) - Bump
org.apache.kafka:kafka-clients3.9.1 → 3.9.2 (#3111)
📚 Documentation
- Add "Insert If Not Exists" section to Lookup Joins documentation (#3037)
- Fix RustFS
AssumeRoledocumentation (#3058)