VVR 8.0.5, nouvelle version du moteur Ververica Runtime (VVR) pour Realtime Compute for Apache Flink, est disponible depuis le 4 janvier 2024. Ce moteur Flink de niveau entreprise, basé sur Apache Flink 1.17.2, intègre des mises à jour de connecteurs, des améliorations de performances et des corrections de bogues.
Cette version fait l'objet d'un déploiement progressif. Si les nouvelles fonctionnalités n'apparaissent pas encore dans votre environnement Flink entièrement géré, la mise à niveau n'a pas atteint votre compte. Pour demander une mise à niveau anticipée, ouvrez un ticket. Pour suivre la progression du déploiement, consultez la dernière annonce sur la page d'accueil de la console Realtime Compute for Apache Flink.
Présentation
VVR 8.0.5 met à jour plusieurs connecteurs et corrige des défauts hérités d'Apache Flink 1.17.2, y compris des correctifs de la communauté Apache Flink. Cette version apporte également des améliorations de stabilité spécifiques au moteur.
Une fois le déploiement progressif terminé, mettez à niveau vos déploiements vers cette version. Pour plus d'informations, consultez Mettre à niveau la version du moteur des déploiements.
Fonctionnalités
| Fonctionnalité | Modifications apportées | Références |
|---|---|---|
| MySQL CDC : spécification d'un offset ou d'un horodatage de départ | La lecture depuis une table source MySQL Change Data Capture (CDC) prend désormais en charge un offset ou un horodatage de départ. Cette fonctionnalité localise directement la position de lecture et accélère l'ingestion des données. | Connecteur MySQL |
| Connecteur MongoDB : synchronisation du schéma et ajout automatique de colonnes pour les tables sources | Avec une table source MongoDB, les instructions CREATE TABLE AS et CREATE DATABASE AS synchronisent les modifications de schéma vers la table de résultats et ajoutent automatiquement les colonnes correspondantes. |
Instruction CREATE TABLE AS, Instruction CREATE DATABASE AS |
| Connecteur MongoDB : prise en charge des tables de dimension | Le connecteur MongoDB fonctionne désormais avec les tables de dimension pour exécuter des requêtes de jointure. | Connecteur MongoDB (préversion publique) |
| Prise en charge du catalog MongoDB | Enregistrez les métadonnées via un catalog MongoDB pour déduire automatiquement le schéma d'une collection. Vous évitez ainsi de rédiger des instructions DDL pour créer une table source MongoDB en SQL. | Gérer les catalogs MongoDB (préversion publique) |
| Connecteur JDBC : prise en charge des types JSONB et UUID | Le connecteur JDBC gère désormais les données des types d'extension JSONB et UUID. | Connecteur JDBC |
| Connecteur Hologres : transmission chiffrée par SSL | Les opérations de lecture et d'écriture utilisent désormais le chiffrement SSL pour sécuriser les communications. | Connecteur Hologres |
| Connecteur Hologres : mode bulkload | L'écriture de données en mode bulkload réduit considérablement la charge d'écriture dans une table de résultats Hologres. | Connecteur Hologres |
| Connecteur Hologres : déduplication lors du traitement par lots | Si sdkMode est défini sur jdbc ou jdbc_fixed, la déduplication s'applique pendant le traitement par lots. Cela améliore la cohérence des données et les performances de la base de données tout en réduisant la surcharge réseau. |
Connecteur Hologres |
**Connecteur Hologres : suppression du paramètre jdbcBinlogSlotName** |
À partir de Hologres V2.1, la configuration du paramètre jdbcBinlogSlotName n'est plus requise. Ce paramètre servait à spécifier le nom du slot d'une table source de journal binaire en mode JDBC. |
Connecteur Hologres, Utiliser le connecteur Hologres pour consommer des données Hologres en temps réel |
| Nouveau connecteur PolarDB for Oracle 1.0 | Le connecteur PolarDB for Oracle 1.0 est disponible. Utilisez-le pour écrire des données dans PolarDB for PostgreSQL (Compatible with Oracle). | Connecteur PolarDB for Oracle 1.0 |
| Connecteur StarRocks : prise en charge du type JSON | Les tables de résultats StarRocks acceptent désormais les données de type JSON. | Aucune |
**ApsaraMQ for RocketMQ : paramètre partitionField** |
Configurez le paramètre partitionField sur une table de résultats ApsaraMQ for RocketMQ pour définir un champ comme clé de partition. Les données partageant la même valeur de hachage sont alors écrites dans la même partition. |
Connecteur ApsaraMQ for RocketMQ |
| Connecteur Elasticsearch : prise en charge de la version V8.X | Le connecteur Elasticsearch permet désormais l'écriture dans des tables de résultats Elasticsearch V8.X. | Connecteur Elasticsearch |
**Connecteur Elasticsearch : paramètre ignoreKeywordSuffix** |
Pour une table de dimension Elasticsearch, définissez ignoreKeywordSuffix sur true afin d'ignorer le suffixe .keyword des champs de type TEXT. |
Connecteur Elasticsearch |
| Connecteur MySQL : gestion des valeurs nulles | Vous pouvez désormais ignorer les valeurs nulles lors de l'écriture de mises à jour dans une table de résultats MySQL. | Connecteur MySQL |