All Products
Search

This Product

    Realtime Compute for Apache Flink:November 30, 2025

    Document Center

    Realtime Compute for Apache Flink:November 30, 2025

    Last Updated:Mar 26, 2026

    This topic describes the major feature updates and bug fixes in the Realtime Compute for Apache Flink release on November 30, 2025.

    Important

    This upgrade rolls out gradually. Check the latest announcement in the Realtime Compute for Apache Flink console to confirm whether the upgrade is complete for your account. To request an expedited upgrade, submit a ticket.

    Overview

    This release introduces Ververica Runtime (VVR) 11.4.0. Highlights include seven new AI functions in Flink SQL, Flink Change Data Capture (CDC) 3.5 alignment, new PostgreSQL CDC and MongoDB source connectors, connector enhancements for Kafka, Hologres, JDBC, Apache Paimon, and Redis, a new PostgreSQL catalog, and platform improvements for namespace management, access control, and operational visibility.

    Area What's new
    Engine — AI Seven new Flink SQL AI functions for text processing
    Engine — Data ingestion Flink CDC 3.5 alignment; PostgreSQL CDC source (Public Preview); MongoDB source
    Engine — Connectors Kafka, Hologres, JDBC, Apache Paimon, Redis enhancements
    Catalog New PostgreSQL catalog; StarRocks and MaxCompute catalog improvements
    Platform Namespace cloning, monitoring service change, access control granularity, RAM-based log archiving
    Bug fixes Kafka connector, Prometheus Metric Reporter, MySQL CDC, hybrid billing, namespace

    Engine

    AI features

    VVR 11.4.0 adds seven AI functions to Flink SQL for text processing in streaming pipelines.

    Function Description Use case
    Text classification Classifies text into preset categories and returns a confidence score Ticket categorization, content tagging
    Sentiment analysis Returns a quantitative sentiment score with a positive, negative, or neutral label Comment analysis, public opinion monitoring
    Information extraction Extracts structured data such as names and phone numbers from unstructured text using a JSON schema —
    Text summarization Generates a summary of long text with a configurable maximum length —
    Text vectorization Creates high-dimensional vector representations of text Similarity calculations, semantic retrieval
    Text translation Translates text across more than 10 languages with automatic source-language detection —
    Data masking Masks sensitive information such as phone numbers and ID card numbers in text Privacy compliance, PII protection

    Data ingestion

    • Flink CDC 3.5 alignment — Aligns with Apache Flink CDC 3.5.

    • PostgreSQL CDC — Public Preview — Adds PostgreSQL as a CDC source connector.

    • MongoDB — Adds MongoDB as a source connector.

    Connectors

    Kafka

    • The Canal-JSON format now supports parsing source database index events. You can also fetch the original key and value as metadata.

    • Supports Protocol Buffers v3 (proto3).

    Hologres

    • Dimension table lookup joins support filter pushdown.

    • Stream Copy supports the BinaryRow format.

    • Supports configuring primary-key conflict strategies for INSERT operations.

    JDBC (PostgreSQL)

    • Adds the ignore delete option to ignore delete events from the source table.

    Apache Paimon

    • Supports cross-partition updates.

    • Supports a username prefix to make jobs easier to locate.

    Redis

    • Enhanced support for cluster instances and batch writes.

    Catalog

    • PostgreSQL catalog — New — Introduces a PostgreSQL catalog for managing PostgreSQL metadata in Flink SQL.

    • StarRocks catalog — Supports treating nullable primary key columns in StarRocks as non-nullable.

    • MaxCompute catalog — Supports mapping a database to a MaxCompute project or schema.

    Platform

    Core features

    Copy namespaces across workspaces for migration and dual-run testing

    Namespace cloning lets you copy a namespace to other workspaces. Use this when migrating clusters or running dual-run tests before cutover.

    Change the monitoring service for a workspace directly in the console

    You can now manually change the monitoring service for your workspace in the console.

    Finer-grained access control for disabled permissions and Git integration

    • Configure disabled permission points for access control.

    • Set granular permissions for Git integration independently of other access control rules.

    Archive logs to Simple Log Service (SLS) via RAM instead of AccessKey pairs

    Log archiving now uses Resource Access Management (RAM) for authentication rather than AccessKey pairs to improve security.

    User experience

    O&M page now shows dynamic update and automatic tuning outcomes

    The Operations & Maintenance (O&M) page displays the status and results of dynamic updates and automatic tuning.

    Billing tags applied automatically in hybrid billed workspaces

    In a hybrid billed workspace, resources are automatically tagged as subscription or pay-as-you-go for easier split billing.

    Search resources by workspace, workspace ID, or namespace

    The resource search now accepts workspace name, workspace ID, or namespace as search criteria.

    Major bug fixes

    • Kafka connector: Fixed an issue where jobs would suspend due to transaction backlogs.

    • Prometheus Metric Reporter: Fixed a buffer overflow caused by unclosed network connections.

    • MySQL CDC: Fixed an issue that prevented reading archived binary logging files from OSS.

    • Hybrid billing: Fixed an error that canceling the order during activation would result in reactivation failures.

    • Namespace: Corrected a bug that prevented Development Console logon by ensuring the last namespace cannot be deleted.