Cette rubrique décrit les mises à jour majeures des fonctionnalités et les corrections de bugs de la version Realtime Compute for Apache Flink du 30 novembre 2025.
Le déploiement s'effectue progressivement. Consultez la dernière annonce dans la console Realtime Compute for Apache Flink pour vérifier si la mise à niveau est terminée pour votre compte. Pour demander une accélération du déploiement, soumettez un ticket.
Vue d'ensemble
Cette version introduit Ververica Runtime (VVR) 11.4.0. Les nouveautés incluent sept fonctions d'IA dans Flink SQL, l'alignement avec Flink Change Data Capture (CDC) 3,5, de nouveaux connecteurs source PostgreSQL CDC et MongoDB, des améliorations des connecteurs pour Kafka, Hologres, JDBC, Apache Paimon et Redis, un nouveau catalogue PostgreSQL, ainsi que des améliorations de la plateforme concernant la gestion des namespace, le contrôle d'accès et la visibilité opérationnelle.
| Domaine | Nouveautés |
|---|---|
| Moteur — IA | Sept nouvelles fonctions d'IA Flink SQL pour le traitement de texte |
| Moteur — Ingestion de données | Alignement avec Flink CDC 3,5 ; source PostgreSQL CDC (Public Preview) ; source MongoDB |
| Moteur — Connecteurs | Améliorations pour Kafka, Hologres, JDBC, Apache Paimon et Redis |
| Catalogue | Nouveau catalogue PostgreSQL ; améliorations des catalogues StarRocks et MaxCompute |
| Plateforme | Clonage de namespace, modification du service de surveillance, granularité du contrôle d'accès, archivage des logs basé sur RAM |
| Corrections de bugs | Connecteur Kafka, Prometheus Metric Reporter, MySQL CDC, facturation hybride, namespace |
Moteur
Fonctionnalités d'IA
VVR 11.4.0 ajoute sept fonctions d'IA à Flink SQL pour le traitement de texte dans les pipelines en streaming.
| Fonction | Description | Cas d'utilisation |
|---|---|---|
| Classification de texte | Classe le texte dans des catégories prédéfinies et renvoie un score de confiance | Catégorisation des tickets, étiquetage de contenu |
| Analyse des sentiments | Renvoie un score quantitatif des sentiments avec une étiquette positive, négative ou neutre | Analyse des commentaires, surveillance de l'opinion publique |
| Extraction d'informations | Extrait des données structurées telles que les noms et numéros de téléphone à partir de texte non structuré à l'aide d'un schéma JSON | — |
| Résumé de texte | Génère un résumé d'un long texte avec une longueur maximale configurable | — |
| Vectorisation de texte | Crée des représentations vectorielles haute dimension du texte | Calculs de similarité, récupération sémantique |
| Traduction de texte | Traduit le texte dans plus de 10 langues avec détection automatique de la langue source | — |
| Masquage des données | Masque les informations sensibles telles que les numéros de téléphone et les numéros de carte d'identité dans le texte | Conformité à la confidentialité, protection des PII |
Ingestion de données
Alignement avec Flink CDC 3,5 — Alignement sur Apache Flink CDC 3,5.
**PostgreSQL CDC — Public Preview** — Ajoute PostgreSQL en tant que connecteur source CDC.
**MongoDB** — Ajoute MongoDB en tant que connecteur source.
Connecteurs
Kafka
Le format Canal-JSON prend désormais en charge l'analyse des événements d'index de la base de données source. Vous pouvez également récupérer la clé et la valeur d'origine en tant que métadonnées.
Prise en charge de Protocol Buffers v3 (proto3).
Hologres
Les jointures de recherche de table de dimension prennent en charge le pushdown de filtre.
Stream Copy prend en charge le format BinaryRow.
Configuration possible des stratégies de conflit de clé primaire pour les opérations INSERT.
JDBC (PostgreSQL)
Ajout de l'option
ignore deletepour ignorer les événements de suppression de la table source.
Apache Paimon
Prise en charge des mises à jour inter-partitions.
Prise en charge d'un préfixe de nom d'utilisateur pour faciliter la localisation des jobs.
Redis
Amélioration de la prise en charge des instances cluster et des écritures par lot.
Catalogue
**Catalogue PostgreSQL — Nouveau** — Introduction d'un catalogue PostgreSQL pour gérer les métadonnées PostgreSQL dans Flink SQL.
**Catalogue StarRocks** — Prise en charge du traitement des colonnes de clé primaire acceptant les valeurs nulles dans StarRocks comme non nulles.
**Catalogue MaxCompute** — Possibilité de mapper une base de données à un projet ou un schéma MaxCompute.
Plateforme
Fonctionnalités principales
Copier des namespace entre espaces de travail pour la migration et les tests en double exécution
Le clonage de namespace permet de copier un namespace vers d'autres espaces de travail. Utilisez cette fonctionnalité lors de la migration de clusters ou pour effectuer des tests en double exécution avant le basculement.
Modifier directement le service de surveillance d'un espace de travail dans la console
Vous pouvez désormais modifier manuellement le service de surveillance de votre espace de travail directement dans la console.
Contrôle d'accès plus fin pour les permissions désactivées et l'intégration Git
Configurez les points de permission
disabledpour le contrôle d'accès.Définissez des permissions granulaires pour l'intégration Git indépendamment des autres règles de contrôle d'accès.
Archiver les logs vers Simple Log Service (SLS) via RAM au lieu des paires AccessKey
L'archivage des logs utilise désormais Resource Access Management (RAM) pour l'authentification plutôt que des paires AccessKey, afin d'améliorer la sécurité.
Expérience utilisateur
La page O&M affiche désormais les résultats des mises à jour dynamiques et du réglage automatique
La page Operations & Maintenance (O&M) affiche l'état et les résultats des mises à jour dynamiques et du réglage automatique.
Étiquettes de facturation appliquées automatiquement dans les espaces de travail à facturation hybride
Dans un espace de travail à facturation hybride, les ressources sont automatiquement étiquetées comme subscription ou pay-as-you-go pour faciliter la répartition de la facturation.
Rechercher des ressources par espace de travail, ID d'espace de travail ou namespace
La recherche de ressources accepte désormais le nom de l'espace de travail, l'ID de l'espace de travail ou le namespace comme critères de recherche.
Corrections de bugs majeures
Connecteur Kafka : Correction d'un problème entraînant la suspension des jobs en raison d'accumulations de transactions.
Prometheus Metric Reporter : Correction d'un dépassement de tampon causé par des connexions réseau non fermées.
MySQL CDC : Correction d'un problème empêchant la lecture des fichiers de journalisation binaire archivés depuis OSS.
Facturation hybride : Correction d'une erreur qui provoquait des échecs de réactivation lors de l'annulation de la commande pendant l'activation.
Namespace : Correction d'un bug empêchant la connexion à la Development Console en veillant à ce que le dernier namespace ne puisse pas être supprimé.