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.
Service géré Amazon pour Apache Flink 1.20
Le service géré pour Apache Flink prend désormais en charge la version 1.20.5 d'Apache Flink. Cette section présente les principales nouvelles fonctionnalités et modifications introduites avec la prise en charge d'Apache Flink par Managed Service for Apache Flink 1.20.5. Apache Flink 1.20 devrait être la dernière version 1.x et une version de support à long terme (LTS) de Flink. Pour plus d'informations, consultez FLIP-458 : Long-Term Support pour la version finale de la gamme Apache Flink 1.x.
Note
Si vous utilisez une version antérieure d'Apache Flink prise en charge et que vous souhaitez mettre à niveau vos applications existantes vers Apache Flink 1.20.5, vous pouvez le faire en utilisant les 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 ARN unique pour toutes les versions d'Apache Flink, y compris les instantanés, les journaux, les métriques, les balises, les configurations Flink, etc.
Fonctionnalités prises en charge
Apache Flink 1.20.5 apporte des améliorations aux API SQL, aux API et au DataStream tableau de bord Flink.
| Fonctionnalités prises en charge | Description | Référence de la documentation Apache Flink |
|---|---|---|
| Ajouter la clause DISTRIBUTED BY | De nombreux moteurs SQL exposent les concepts de PartitioningBucketing, ouClustering. Flink 1.20 introduit le concept de Bucketing Flink. |
FLIP-376: Ajouter la clause DISTRIBUTED BY |
| DataStream API : prend en charge le traitement complet des partitions | Flink 1.20 introduit la prise en charge intégrée des agrégations sur des flux non clés via l'API. FullPartitionWindow |
FLIP-380: Supporte le traitement complet des partitions sur Non-keyed DataStream |
| Afficher le score d'asymétrie des données sur le tableau de bord Flink | Le tableau de bord de Flink 1.20 affiche désormais des informations sur l'asymétrie des données. Chaque opérateur de l'interface utilisateur du graphique des tâches de Flink affiche un score d'asymétrie des données supplémentaire. | FLIP-418: Afficher le score d'asymétrie des données sur le tableau de bord Flink |
Pour la documentation de la version 1.20.5 d'Apache Flink, consultez la documentation d'Apache Flink v1.20.5
Éléments
| Composant | Version |
|---|---|
| Java | 11 (recommandée) |
| Python |
3,11 |
| Durée d'exécution de Kinesis Data Analytics Flink (aws-kinesisanalytics-runtime) | 1.2.0 |
| Connecteurs | Pour plus d'informations sur les connecteurs disponibles, consultez la section Connecteurs https://docs.aws.amazon.com/managed-flink/latest/java/how-flink-connectors.html Apache Flink. |
| Apache Beam (applications Beam uniquement) |
À partir de la version 2.70.0. Pour plus d'informations, consultez la section Compatibilité des versions de |
Problèmes connus
Service géré Amazon pour Apache Flink Studio
Amazon Managed Service pour Apache Flink Studio utilise les blocs-notes Apache Zeppelin pour fournir une expérience de développement à interface unique permettant de développer, de déboguer du code et d'exécuter des applications de traitement de flux Apache Flink. Une mise à niveau de l'interpréteur Flink de Zeppelin est requise pour permettre la prise en charge de Flink 1.20. Ce travail est programmé avec la communauté Zeppelin. Nous mettrons à jour ces notes lorsque ce travail sera terminé. Vous pouvez continuer à utiliser Flink 1.15 avec Amazon Managed Service pour Apache Flink Studio. Pour plus d'informations, voir Création d'un bloc-notes Studio.
Corrections de bugs rétroportées
Amazon Managed Service for Apache Flink rétroporte les correctifs de la communauté Flink pour des problèmes critiques. Voici une liste des corrections de bogues que nous avons rétroportées :
| Lien vers Apache Flink JIRA | Description |
|---|---|
| FLINK-35886 |
Ce correctif résout un problème à l'origine d'une comptabilisation incorrecte des délais d'inactivité des filigranes lorsqu'une sous-tâche est exécutée. backpressured/blocked |
