Le débit est trop lent - Service géré pour Apache Flink
SymptômesCauses et solutions

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.

Le débit est trop lent

Si votre application ne traite pas assez rapidement les données de streaming entrantes, elle fonctionnera mal et deviendra instable. Cette section décrit les symptômes et les étapes de résolution de ce problème.

Symptômes

Ce problème peut présenter les symptômes suivants :

  • Si la source de données de votre application est un flux Kinesis, la métrique millisbehindLatest du flux augmente continuellement.

  • Si la source de données de votre application est un MSK cluster Amazon, les indicateurs de latence du cluster en termes de consommation augmentent continuellement. Pour plus d'informations, consultez Consumer-Lag Monitoring dans le manuel Amazon MSK Developer Guide.

  • Si la source de données de votre application est un autre service ou une autre source, vérifiez les métriques de retard des consommateurs ou les données disponibles.

Causes et solutions

Le ralentissement du débit des applications peut avoir de nombreuses causes. Si votre application ne suit pas le rythme des entrées, vérifiez les points suivants :

  • Si le retard de débit augmente puis diminue, vérifiez si l’application redémarre. Votre application arrêtera de traiter les entrées pendant le redémarrage, ce qui provoquera un pic de retard. Pour obtenir des informations sur les échecs d’application, consultez L'application redémarre.

  • Si le retard de débit est constant, vérifiez si les performances de votre application sont optimisées. Pour plus d’informations sur l’optimisation des performances de votre application, consultez Résoudre les problèmes de performances.

  • Si le retard de débit n’augmente pas de manière excessive, mais augmente continuellement et que les performances de votre application sont optimisées, vous devez augmenter les ressources de votre application. Pour plus d’informations sur l’augmentation des ressources d’application, consultezImplémenter le dimensionnement des applications dans le service géré pour Apache Flink.

  • Si votre application lit à partir d’un cluster Kafka situé dans une autre région et que FlinkKafkaConsumer ou KafkaSource sont principalement inactifs (idleTimeMsPerSecond élevé ou CPUUtilization faible) malgré un retard important pour les consommateurs, vous pouvez augmenter la valeur pour receive.buffer.byte, par exemple 2097152. Pour plus d'informations, consultez la section relative à l'environnement à latence élevée dans MSKConfigurations personnalisées.

Pour les étapes de résolution des problèmes liés au ralentissement du débit ou à l’augmentation du retard des consommateurs dans la source de l’application, consultez Résoudre les problèmes de performances.