Le service géré Amazon pour Apache Flink était auparavant connu sous le nom d’Amazon Kinesis Data Analytics pour Apache Flink.
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.
FlinkKafkaConsumer problème avec l'arrêt avec le point de sauvegarde
Lorsque vous utilisez l'ancienne versionUPDATING, FlinkKafkaConsumer il est possible que votre application reste bloquée STOPPING ou que SCALING les instantanés du système soient activés. Aucun correctif publié n'est disponible pour ce problème
Si vous utilisez le FlinkKafkaConsumer
avec les instantanés activés, il est possible que lorsque la tâche Flink traite une API demande d'arrêt avec point de sauvegarde, échoue en raison d'une erreur d'exécution signalant un. FlinkKafkaConsumer
ClosedException
Dans ces conditions, l’application Flink se bloque, indiquant des points de contrôle défaillants.