FlinkKafkaConsumer problème avec l'arrêt avec le point de sauvegarde - Service géré pour Apache Flink

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. Nous vous recommandons donc de passer à la nouvelle version afin KafkaSourced'atténuer 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.