Cette version s'appuie sur Ververica Runtime (VVR) 6.0.3 d'Apache Flink 1.15.2. Elle corrige les principaux défauts signalés par la communauté Apache Flink et intègre des améliorations de la plateforme ainsi que des mises à jour des connecteurs.
Si votre déploiement utilise une version de VVR antérieure à la 6.0.3, mettez à niveau vers VVR 6.0.3 dès que possible pour garantir la stabilité de votre environnement de production.
Nouvelles fonctionnalités
Plateforme
Interrogez directement les erreurs à partir des sélections de journaux
Dans les onglets Events et Exploration de la console de développement Realtime Compute for Apache Flink, sélectionnez le texte d'une entrée de journal pour interroger l'erreur associée. Les résultats affichent la cause et la solution recommandée, ce qui vous permet de dépanner sans quitter la console.
Optimisation des messages d'erreur de syntaxe SQL
La vérification de la syntaxe SQL renvoie désormais des messages d'erreur plus clairs, ce qui accélère l'identification et la correction des syntaxes invalides.
Connecteurs et catalogs
Configurez un mécanisme de nouvelle tentative pour les écritures MaxCompute
Définissez une politique de nouvelle tentative pour l'écriture des données dans MaxCompute afin d'éviter les échecs des opérations COMMIT ou createUploadSession en cas d'interruptions de service au sein d'un cluster Tunnel. Vos jobs d'écriture restent ainsi résilients sans intervention manuelle.
Créez ou supprimez des colonnes non nullables dans les déploiements CREATE DATABASE AS
Les déploiements utilisant l'instruction CREATE DATABASE AS prennent désormais en charge la création et la suppression de colonnes non nullables.
Alignez le schéma du catalog Kafka JSON sur l'ordre des colonnes du message JSON
Le schéma déduit par un catalog Kafka JSON correspond désormais à la séquence des colonnes du message JSON source, éliminant ainsi les incohérences de schéma causées par la réorganisation des colonnes.
Tolérance à la syntaxe invalide de création de table dans ApsaraDB RDS
Realtime Compute for Apache Flink est désormais compatible avec la syntaxe invalide de création de table dans les bases de données ApsaraDB RDS. L'exécution des tâches Change Data Capture (CDC) n'est pas interrompue lorsqu'une syntaxe invalide est rencontrée.
Corrections de bugs
Le paramètre sink.parallelism était ignoré lors de la synchronisation Kafka via CREATE DATABASE AS
Le paramètre sink.parallelism prend désormais effet lorsque vous utilisez CREATE DATABASE AS pour synchroniser les données vers Kafka.
Erreur ClassCastException dans les déploiements CREATE DATABASE AS (VVR 6.0.2)
Les déploiements utilisant CREATE DATABASE AS ne génèrent plus d'erreur ClassCastException.
Absence d'affichage des graphiques de métriques de latence pour les tables source MySQL CDC (VVR 6.0.2)
Les courbes représentant les métriques liées à la latence des tables source MySQL CDC s'affichent désormais correctement.
La syntaxe des indices SQL n'était pas appliquée (VVR 6.0.2)
Les indices SQL prennent désormais effet comme prévu lors de l'exécution des requêtes.
Un conflit de classes était signalé à tort comme une exception de données hors limites lors des vérifications de syntaxe (VVR 6.0.2)
Les conflits de classes détectés lors des vérifications de syntaxe sont désormais signalés avec précision, au lieu d'être classés à tort comme des exceptions de données hors limites.
Conflit d'ID de serveur lors de l'écriture d'une table vers plusieurs sinks via CREATE TABLE AS (VVR 6.0.2)
Il n'y a plus de conflit d'ID de serveur lorsqu'un déploiement CREATE TABLE AS écrit les données d'une table vers plusieurs sinks.
Interblocage du JobManager dû à l'élection du leader dans les clusters Kubernetes
Le JobManager ne subit plus d'interblocage lors de l'élection du leader dans les clusters Kubernetes.
Erreur « Decrease reference to an unknown file » dans GeminiStateBackend
Le backend d'état GeminiStateBackend ne produit plus d'erreurs « Decrease reference to an unknown file ».