Skip to content

Commit cd0fcd7

Browse files
committed
update and address comments
1 parent c44cb07 commit cd0fcd7

File tree

1 file changed

+35
-16
lines changed

1 file changed

+35
-16
lines changed

website/blog/releases/0.8.md

Lines changed: 35 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -1,22 +1,22 @@
11
---
2-
title: "Apache Fluss 0.8: Streaming Lakehouse with Iceberg/Lance"
2+
title: "Announcing Apache Fluss 0.8: Streaming Lakehouse for Data + AI"
33
sidebar_label: "Announcing Apache Fluss 0.8"
44
authors: [giannis, jark]
5-
date: 2025-10-30
5+
date: 2025-11-08
66
tags: [releases]
77
---
88

99
![Banner](../assets/0.8/banner.jpg)
1010

11-
🌊 We are excited to announce the official release of **Apache Fluss 0.8**!
11+
🌊 We are excited to announce the official release of **Apache Fluss 0.8 (incubating)**!
1212

13-
This marks the first Apache Software Foundation (ASF) release for Apache Fluss (incubating), marking a significant milestone in our journey to provide a robust streaming storage platform for real-time analytics.
13+
This is our first release under the incubator of the Apache Software Foundation, marking a significant milestone in our journey to provide a robust streaming storage platform for real-time analytics.
1414

15-
Over the past four months, the community has made tremendous progress, delivering 390+ commits that push the boundaries of the Streaming Lakehouse ecosystem. This release introduces deeper integrations, performance breakthroughs, and next-generation stream processing capabilities, including:
15+
Over the past four months, the community has made tremendous progress, delivering nearly 400 commits that push the boundaries of the Streaming Lakehouse ecosystem. This release introduces deeper integrations, performance breakthroughs, and next-generation stream processing capabilities, including:
1616

1717
* 🔗 Tighter integration with Apache Flink for seamless real-time processing.
1818
* 🧊 Enhanced Streaming Lakehouse capabilities with full support for [Apache Iceberg](https://iceberg.apache.org/) and [Lance](https://lancedb.github.io/lance/)
19-
* ⚡ Introduction of [Delta Joins](https://cwiki.apache.org/confluence/display/FLINK/FLIP-486%3A+Introduce+A+New+DeltaJoin), a game-changing innovation that redefines efficiency in stream processing by minimizing state and maximizing speed.
19+
* ⚡ Introduction of [Delta Joins](https://cwiki.apache.org/confluence/display/FLINK/FLIP-486%3A+Introduce+A+New+DeltaJoin) with Flink, a game-changing innovation that redefines efficiency in stream processing by minimizing state and maximizing speed.
2020

2121
Apache Fluss 0.8 marks the beginning of a new era in streaming:
2222
**real-time**, **unified**, and **zero-state**, purpose-built to power the next generation of data platforms with **low-latency performance**, **scalability**, and **architectural simplicity**.
@@ -51,11 +51,11 @@ datalake.iceberg.type: hadoop
5151
datalake.iceberg.warehouse: /path/to/iceberg
5252
```
5353
54-
You can find more detailed instructions in the [documentation](/docs/next/streaming-lakehouse/integrate-data-lakes/iceberg/).
54+
You can find more detailed instructions in the [Iceberg Lakehouse documentation](/docs/next/streaming-lakehouse/integrate-data-lakes/iceberg/).
5555
5656
## Real-Time Multimodal AI Analytics with Lance
5757
58-
Another major enhancement in Fluss 0.8 is the addition of **Streaming Lakehouse support for [Lance](https://github.com/lancedb/lance)** ([FIP-5](https://cwiki.apache.org/confluence/display/FLUSS/FIP-5%3A+Support+tiering+Fluss+data+to+Lance),
58+
Another major enhancement in Fluss 0.8 is the addition of **Streaming Lakehouse support for [Lance](https://github.com/lancedb/lance)** ([FIP-5](https://cwiki.apache.org/confluence/display/FLUSS/FIP-5%3A+Support+tiering+Fluss+data+to+Lance)),
5959
a modern columnar and vector-native data format designed for AI and machine learning workloads.
6060
This integration extends Apache Fluss towards being a real-time ingestion platform for multi-modal data & AI,
6161
not just traditional tabular streams, but also embeddings, vectors, and unstructured features used in AI systems.
@@ -80,7 +80,7 @@ datalake.lance.access_key_id: <access_key_id>
8080
datalake.lance.secret_access_key: <secret_access_key>
8181
```
8282
83-
See the [LanceDB blog post](https://lancedb.com/blog/fluss-integration/) for the full integration. You also can find more detailed instructions in the [documentation](/docs/next/streaming-lakehouse/integrate-data-lakes/lance/).
83+
See the [LanceDB blog post](https://lancedb.com/blog/fluss-integration/) for the full integration. You also can find more detailed instructions in the [Lance Lakehouse documentation](/docs/next/streaming-lakehouse/integrate-data-lakes/lance/).
8484
8585
## Flink 2.1
8686
@@ -102,7 +102,7 @@ Below is a performance comparison (CPU, memory, state size, checkpoint interval)
102102
![](../assets/taobao_practice/performance_delta2.png)
103103
104104
105-
TODO: add documentation link
105+
You can find more detailed instructions in the [Delta Join documentation](/docs/next/engine-flink/delta-joins/).
106106
107107
### Materialized Table
108108
@@ -135,8 +135,7 @@ WITH(
135135
);
136136
```
137137

138-
TODO: add documentation link
139-
138+
You can find more detailed instructions in the [Materialized Table documentation](/docs/next/engine-flink/ddl/#materialized-table).
140139

141140
## Stability
142141

@@ -145,7 +144,7 @@ Through continuous validation across multiple business units within Alibaba Grou
145144
These improvements substantially enhance Fluss’s robustness in mission-critical streaming use cases.
146145

147146
Key improvements include:
148-
- **Graceful Shutdown**: Introduced a graceful shutdown mechanism for TabletServers. During shutdown, leadership is proactively migrated before termination, ensuring that read/write latency remains unaffected by node decommissioning.
147+
- **[Graceful Shutdown](/docs/next/maintenance/operations/graceful-shutdown/)**: Introduced a graceful shutdown mechanism for TabletServers. During shutdown, leadership is proactively migrated before termination, ensuring that read/write latency remains unaffected by node decommissioning.
149148
- **Accelerated Coordinator Event Processing**: Optimized the Coordinator’s event handling mechanism through asynchronous processing and batched ZooKeeper operations. As a result, all events are now processed in milliseconds.
150149
- **Faster Coordinator Recovery**: Parallelized initialization cuts Coordinator startup time from 10 minutes to just 20 seconds in production-scale benchmarks, this dramatically improves service availability and recovery speed.
151150
- **Optimized Server Metrics**: Refined metric granularity and reporting logic to reduce telemetry volume by 90% while preserving full observability.
@@ -155,21 +154,41 @@ With these foundational stability improvements, Fluss 0.8 is now production-read
155154

156155
## Dynamic Configuration
157156

157+
Starting with Fluss version 0.8, certain **cluster-level configurations** and **table-level configurations** can be updated dynamically, without requiring a cluster restart or table recreation. This enables operators and developers to adjust system behavior in real time, improving operational agility and minimizing downtime.
158+
158159
### Dynamic Cluster Configs
159160

160-
TODO: need feature documentation
161+
Fluss now supports runtime updates for cluster configuration parameters. These changes take effect immediately across the cluster after being applied through the API.
162+
163+
```java title="Java Client"
164+
Admin admin = connection.getAdmin();
165+
Collection<AlterConfig> configsToUpdate = Arrays.asList(
166+
new AlterConfig("datalake.format", "paimon", AlterConfigOpType.SET));
167+
admin.alterClusterConfigs(configsToUpdate)
168+
```
161169

162170
### Dynamic Table Configs
163171

164-
TODO: need feature documentation
172+
Fluss now supports update options dynamically on a table using the `ALTER TABLE ... SET` statement. This supports all the client-wise options (like `scan.startup.mode`) and some storage-wise options (like `table.datalake.enabled`).
173+
174+
```sql title="Flink SQL"
175+
-- Enable lakehouse storage for the given table
176+
ALTER TABLE my_table SET ('table.datalake.enabled' = 'true');
177+
```
178+
179+
When you issue a `ALTER TABLE ... SET` command to update storage options on a table, the Fluss cluster validates and applies the new configuration immediately. The updated settings are propagated to all TabletServers and CoordinatorServer components, ensuring consistent behavior going forward.
180+
181+
This capability is especially useful for tuning performance, adapting to changing data patterns, or complying with evolving data governance requirements—all without service interruption.
182+
183+
You can find more detailed instructions in the [Updating Configs documentation](/docs/next/maintenance/operations/updating-configs/).
165184

166185
## Helm Charts
167186

168187
This release also introduced Helm Charts. With this addition, users can now deploy and manage a full Fluss cluster using [Helm](https://helm.sh/).
169188
The Helm chart simplifies provisioning, upgrades, and scaling by packaging configuration, manifests, and dependencies into a single, versioned release.
170189
This should help users running Fluss on Kubernetes faster, more reliably, and with easier integration into existing CI/CD and observability setups, significantly lowering the barrier for teams adopting Fluss in production.
171190

172-
TODO: add documentation link
191+
You can find more detailed instructions in the [Deploying with Helm documentation](/docs/next/install-deploy/deploying-with-helm/).
173192

174193
## Ecosystem
175194

0 commit comments

Comments
 (0)