Ververica Platform 2.14.2
Release Date: 2025-02-14
Upgrading to version 2.14.2 will cause existing running deployments to lose track of checkpointing progress.
Changelog
Apache Flink®
Ververica Platform 2.14.2 supports the following versions:
- Apache Flink® 1.19
- Apache Flink® 1.18
- Apache Flink® 1.17
Ververica Platform 2.14.2 supports Apache Flink® 1.19, Apache Flink® 1.18, and Apache Flink® 1.17 under SLA.
For Stream Edition the following Apache Flink® Docker images are available. Please check Ververica Platform Docker Images for all available Apache Flink® images and additional tags.
- 1.17.2-stream6-scala_2.12-java8
- 1.17.2-stream6-scala_2.12-java11
- 1.18.1-stream5-scala_2.12-java8
- 1.18.1-stream5-scala_2.12-java11
- 1.18.1-stream5-scala_2.12-java17
- 1.19.0-stream3-scala_2.12-java8
- 1.19.0-stream3-scala_2.12-java11
- 1.19.0-stream3-scala_2.12-java17
For Spring Edition the following archives are available:
Features
Introducing Snowflake Sink Connector for Ververica Platform in VVP 2.14.2
We are excited to introduce the Snowflake connector for Ververica Platform, which was previously available only for Ververica Cloud. This new connector is designed as a sink-only connector, allowing users to stream data from various sources directly into Snowflake for storage and analysis.
Using the latest Flink interfaces (Sink<InputT>
and SinkWriter<InputT>
), the connector enables easy and configurable writing of data into Snowflake tables. This addition enhances the flexibility and functionality of the Ververica Platform by offering a seamless integration with Snowflake for users looking to persist and analyze their streaming data.
Improvements
Improved Metrics Link for Historical Jobs in VVP to Include Run Period
In the previous version, when users clicked on Actions for past and current jobs in Ververica Platform, they were directed to the latest metrics in Grafana or OpenSearch, without considering the specific run period of the job. In this release, we've improved the functionality so that the "from" and "to" time parameters are correctly included in the metrics link for both apps, ensuring that users see the metrics for the exact period when the job was executed.
This update improves the user experience by removing the need for manual adjustment of the time range in the dashboards. Users can now directly access the relevant metrics for historical jobs and streamlining the process.
Bug fixes
Fixed JobManager Restart Loop in High Availability Cluster When Job Fails
In VVP 2.14.1, a bug caused the JobManager (JM) pod in a Kubernetes high-availability (HA) setup to enter a restart loop when a job failed. The issue occurred when the job was repeatedly submitted with the same JobID after the job had already reached a terminal FAILED state. This resulted in the JobManager continuously attempting to resubmit the job, but Flink ignored the submission due to the terminal state, leading to a "Cluster Unreachable" status in the VVP UI.
This issue has been resolved to ensure that the JobManager no longer enters a restart loop when a job has previously failed. The system now properly handles job re-submissions and prevents unnecessary retries, improving stability in HA configurations.
In case an installation suffers from this issue, we propose to employ the fail early mechanism (spec.template.spec.flinkFatalExceptionFailEarly
) that has been introduced with the 2.13.3 release and got extended in 2.14.2 to catch more cases.