lsyldliu commented on code in PR #800: URL: https://github.com/apache/flink-web/pull/800#discussion_r2230097750
########## docs/content/posts/2025-07-31-release-2.1.0.md: ########## @@ -0,0 +1,458 @@ +--- +authors: + - reswqa: + name: "Ron Liu" + twitter: "Ron999" + +date: "2025-07-31T08:00:00Z" +subtitle: "" +title: Ushers in a New Era of Unified Real-Time Data + AI with Comprehensive Upgrades +aliases: + - /news/2025/07/31/release-2.1.0.html +--- + +The Apache Flink PMC is proud to announce the release of Apache Flink 2.1.0. This marks a significant milestone +in the evolution of the real-time data processing engine into a unified Data + AI platform. This release brings +together 116 global contributors, implements 15 FLIPs (Flink Improvement Proposals), and resolves over 220 issues, +with a strong focus on deepening the integration of real-time AI and intelligent stream processing: + +1. **Breakthroughs in Real-Time AI**: + - Introduces AI Model DDL, enabling flexible management of AI models through Flink SQL and the Table API. + + - Extends the `ML_PREDICT` Table-Valued Function (TVF), empowering real-time invocation of AI models within Flink SQL, + laying the foundation for building end-to-end real-time AI workflows. + +2. **Enhanced Real-Time Data Processing**: + - Adds the `VARIANT` data type for efficient handling of semi-structured data like JSON. Combined with the `PARSE_JSON` function + and lakehouse formats (e.g., Apache Paimon), it enables dynamic schema data analysis. + + - Significantly optimizes streaming joins with the innovative introduction of `DeltaJoin` and `MultiJoin` strategies, + eliminating state bottlenecks and improving resource utilization and job stability. + +Flink 2.1.0 seamlessly integrates real-time data processing with AI models, empowering enterprises to advance from +real-time analytics to real-time intelligent decision-making, meeting the evolving demands of modern data applications. +We extend our gratitude to all contributors for their invaluable support! + +Let's dive into the highlights. + +# Flink SQL Improvements + +## Model DDLs using Table API Review Comment: fixed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
