VVR 8.0.4 (Ververica Runtime) is an enterprise-grade Flink engine based on Apache Flink 1.17.1. This release includes connector updates, performance optimization, and bug fixes.
Important
The canary release completes within two weeks. If the new version is not yet available for your account, submit a ticket to request an early upgrade. To check the rollout schedule, see the latest announcement on the homepage of the Realtime Compute for Apache Flink console.
After the canary release completes, upgrade your deployments to VVR 8.0.4. For instructions, see Upgrade the engine version of deployments.
New features
| Feature | Description | Reference |
|---|---|---|
| TINYINT(1) and BOOLEAN mapping control for MySQL CDC tables | A new parameter lets you specify which Flink data type MySQL TINYINT(1) and BOOLEAN columns map to, ensuring data consistency when using a MySQL catalog to read table schemas. |
Manage MySQL catalogs |
upsertCommitTimeoutMs parameter for MaxCompute Upsert Tunnel |
The upsertCommitTimeoutMs parameter sets the session commit timeout for MaxCompute Upsert Tunnel uploads, preventing occasional timeout failures. |
MaxCompute connector |
| Auto-increment primary keys and dirty data handling in the Tablestore connector | Result tables now support auto-increment primary keys in the table schema. For source tables, set skipInvalidData to true to skip dirty data, or false to return an error when dirty data is detected. |
Tablestore connector |
| Elasticsearch 8.X support | The Elasticsearch connector now supports Elasticsearch 8.X, extending compatibility with newer cluster versions. | — |
| Hologres connection pool default value changed to database name | The default value of the Hologres connection pool is changed from a fixed value to a database name, which reduces the number of connections used. | Hologres connector |
Bug fixes
| Fix | Description | Reference |
|---|---|---|
| Apache Flink 1.17.1 defect fixes | Multiple bugs in Apache Flink 1.17.1 are fixed in this release, including fixes backported from the Apache Flink community, to improve engine stability and reliability. | — |