VVR 8.0.4 (Ververica Runtime) est un moteur Flink d’entreprise basé sur Apache Flink 1.17.1. Cette version inclut des mises à jour des connecteurs, des optimisations des performances et des corrections de bugs.
Le déploiement progressif (canary release) s’achève sous deux semaines. Si la nouvelle version n’est pas encore disponible pour votre compte, soumettez un ticket pour demander une mise à niveau anticipée. Pour consulter le calendrier de déploiement, reportez-vous à la dernière annonce sur la page d’accueil de la console Realtime Compute for Apache Flink.
Une fois le déploiement progressif terminé, mettez à niveau vos déploiements vers VVR 8.0.4. Pour obtenir des instructions, consultez la rubrique Mettre à niveau la version du moteur des déploiements.
Nouvelles fonctionnalités
| Fonctionnalité | Description | Référence |
|---|---|---|
| Contrôle du mappage TINYINT(1) et BOOLEAN pour les tables MySQL CDC | Un nouveau paramètre vous permet de spécifier le type de données Flink auquel les colonnes MySQL TINYINT(1) et BOOLEAN sont mappées, garantissant ainsi la cohérence des données lors de l’utilisation d’un catalogue MySQL pour lire les schémas de table. |
Gérer les catalogues MySQL |
Paramètre upsertCommitTimeoutMs pour MaxCompute Upsert Tunnel |
Le paramètre upsertCommitTimeoutMs définit le délai d’expiration de la validation de session pour les chargements via MaxCompute Upsert Tunnel, évitant ainsi les échecs occasionnels dus aux délais d’expiration. |
Connecteur MaxCompute |
| Clés primaires auto-incrémentées et gestion des données incorrectes dans le connecteur Tablestore | Les tables de résultats prennent désormais en charge les clés primaires auto-incrémentées dans le schéma de table. Pour les tables source, définissez skipInvalidData sur true pour ignorer les données incorrectes, ou sur false pour renvoyer une erreur lorsque des données incorrectes sont détectées. |
Connecteur Tablestore |
| Prise en charge d’Elasticsearch 8.X | Le connecteur Elasticsearch prend désormais en charge Elasticsearch 8.X, étendant ainsi la compatibilité avec les versions plus récentes des clusters. | — |
| La valeur par défaut du pool de connexions Hologres est remplacée par le nom de la base de données | La valeur par défaut du pool de connexions Hologres passe d’une valeur fixe au nom d’une base de données, ce qui réduit le nombre de connexions utilisées. | Connecteur Hologres |
Corrections de bugs
| Correction | Description | Référence |
|---|---|---|
| Corrections des défauts d’Apache Flink 1.17.1 | Plusieurs bugs présents dans Apache Flink 1.17.1 ont été corrigés dans cette version, notamment des correctifs rétroportés depuis la communauté Apache Flink, afin d’améliorer la stabilité et la fiabilité du moteur. | — |