Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
Amazon Managed Service pour Apache Flink 2.3
Le service géré pour Apache Flink prend désormais en charge la version 2.3.0 d'Apache Flink. Cette section vous présente les principales nouvelles fonctionnalités et modifications apportées à la prise en charge d'Apache Flink 2.3.0 par le service géré pour Apache Flink.
Note
Si vous utilisez une version antérieure prise en charge d'Apache Flink et que vous souhaitez mettre à niveau vos applications existantes vers Apache Flink 2.3.0, vous pouvez le faire en utilisant des mises à niveau de version d'Apache Flink sur place. Pour de plus amples informations, veuillez consulter Utiliser des mises à niveau de version sur place pour Apache Flink. Grâce aux mises à niveau de version sur place, vous conservez la traçabilité des applications par rapport à un seul ARN pour toutes les versions d'Apache Flink, y compris les instantanés, les journaux, les métriques, les balises, les configurations Flink, etc.
Note
La mise à niveau de Flink 1.x vers Flink 2.3 est une mise à niveau majeure avec des modifications majeures et des considérations de compatibilité des états. Avant de procéder à la mise à niveau depuis la version 1.x, consultez Changements majeurs et dépréciations et. Guide de compatibilité d'état pour les mises à niveau de Flink 2.2
Fonctionnalités prises en charge
Apache Flink 2.3.0 apporte des améliorations à l'API SQL, à la sélection adaptative des partitions pour les charges de travail asymétriques et au tableau de bord Flink.
Fonctionnalités prises en charge |
Description |
Référence de documentation Apache Flink |
|---|---|---|
Améliorations SinkUpsertMaterializer et troubles du journal des modifications |
Améliore l'ordre des mises à jour lors de l'écriture de flux CDC ou de changelog pour remplacer les récepteurs. |
FLIP-558: Améliorations SinkUpsertMaterializer et troubles du journal des modifications |
Gestion des applications (lire les API) |
Nouveaux points de terminaison en lecture seule pour l'observabilité au niveau de l'application. Les points de terminaison d'écriture sont désactivés dans Amazon Managed Service pour Apache Flink. |
FLIP-549: Gestion des applications |
Sélection de partition adaptative pour StreamPartitioner |
Opt-in optimisation du débit pour les partitionneurs |
FLIP-339: Sélection de partition adaptative pour StreamPartitioner |
Note
Vous pouvez opter pour les fonctionnalités suivantes en soumettant un dossier d'assistance
Opt-in features |
Description |
Référence de documentation Apache Flink |
|---|---|---|
Point de contrôle de support pendant la récupération |
Ceci est désactivé par défaut car il s'agit d'une fonctionnalité expérimentale en open source. Vous pouvez demander à l'activer pour votre application à l'aide d'un dossier d'assistance. |
FLIP-547: Point de contrôle de support pendant la restauration |
Pour la documentation de la version 2.3.0 d'Apache Flink, consultez la documentation Apache Flink
Modifications apportées à Amazon Managed Service pour Apache Flink avec Apache Flink 2.3
L'alignement des filigranes est conservé par défaut
Apache Flink 2.3 modifie le comportement par défaut de l'alignement des filigranes afin d'éviter que les tâches en attente ne consomment toutes les ressources en aval. Dans Amazon Managed Service pour Apache Flink, la valeur par défaut de pipeline.watermark-alignment.max-drift est définie 0 pour préserver la rétrocompatibilité avec les versions antérieures d'Apache Flink prises en charge et protéger vos applications existantes contre une régression comportementale lors de la mise à niveau. Si vous souhaitez bénéficier du nouveau comportement d'équité, vous pouvez l'activer en le définissant par pipeline.watermark-alignment.max-drift programmation dans le code de votre application. Pour plus d'informations, voir FLINK-37399: L'alignement des filigranes empêche les tâches en attente d'utiliser toutes les ressources
Éléments
Composant |
Version |
|---|---|
Java |
17 (recommandé) |
Python |
3,12 |
Kinesis Data Analytics Flink Runtime (aws-kinesisanalytics-runtime) |
1.2.0 |
Connecteurs |
Pour plus d'informations sur les connecteurs disponibles, consultez la section Connecteurs Apache Flink. |
Fonctionnalités expérimentales et non prises en charge
Les fonctionnalités Apache Flink 2.3 suivantes ne sont pas prises en charge dans Amazon Managed Service pour Apache Flink :
Tables matérialisées : instantanés de table interrogeables et maintenus en permanence.
Modifications de télémétrie personnalisées : rapports métriques personnalisés et configurations de télémétrie.
-
Flink Native S3 FileSystem (FLIP-555) : Implémentation du système de fichiers S3 natif (expérimental en open source)
-
ForSt State Backend : stockage d'état désagrégé (expérimental en open source).
-
Java 21 : support expérimental en open source, non pris en charge dans Managed Service pour Apache Flink.
Service géré Amazon pour Apache Flink Studio
Dans Amazon Managed Service pour Apache Flink, Flink 2.3 ne prend pas en charge les applications Studio. Pour plus d'informations, consultez la section Création d'un bloc-notes Studio.
