A taxa de transferência é muito lenta - Managed Service for Apache Flink
SintomasCausas e soluções

Anteriormente, o Amazon Managed Service for Apache Flink era conhecido como Amazon Kinesis Data Analytics for Apache Flink.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

A taxa de transferência é muito lenta

Se seu aplicativo não estiver processando os dados de transmissão recebidos com rapidez suficiente, ele terá um desempenho insatisfatório e ficará instável. Esta seção descreve os sintomas e as etapas de solução de problemas dessa condição.

Sintomas

Essa condição pode ter os seguintes sintomas:

  • Se a fonte de dados do seu aplicativo for um fluxo do Kinesis, a métrica millisbehindLatest do fluxo aumentará continuamente.

  • Se a fonte de dados do seu aplicativo for um MSK cluster da Amazon, as métricas de atraso do consumidor do cluster aumentam continuamente. Para obter mais informações, consulte Consumer-Lag Monitoring no Amazon Developer Guide. MSK

  • Se a fonte de dados do seu aplicativo for um serviço ou fonte diferente, verifique todas as métricas de atraso do consumidor ou dados disponíveis.

Causas e soluções

Pode haver muitas causas para o throughput baixo do aplicativo. Se seu aplicativo não estiver acompanhando as entradas, verifique o seguinte:

  • Se o atraso no throughput estiver aumentando e depois diminuindo, verifique se o aplicativo está sendo reiniciado. Seu aplicativo interromperá o processamento da entrada enquanto for reiniciado, causando um aumento no atraso. Para obter informações sobre falhas do aplicativo, consulte O aplicativo está sendo reiniciado.

  • Se o atraso no throughput for consistente, verifique se seu aplicativo está otimizado para desempenho. Para obter informações sobre como otimizar o desempenho do seu aplicativo, consulte Solucionar problemas de desempenho.

  • Se o atraso no throughput não aumentar repentinamente, mas estiver aumentando continuamente, e seu aplicativo estiver otimizado para desempenho, você deverá aumentar os recursos do aplicativo. Para obter informações sobre o aumento dos recursos do aplicativo, consulte Implemente o escalonamento de aplicativos.

  • Se seu aplicativo lê de um cluster do Kafka em uma região diferente e FlinkKafkaConsumer ou KafkaSource está quase inativo (idleTimeMsPerSecond alto ou CPUUtilization baixo) apesar do alto atraso do consumidor, você pode aumentar o valor para receive.buffer.byte, como 2097152. Para obter mais informações, consulte a seção Ambiente de alta latência em MSKConfigurações personalizadas.

Para obter as etapas de solução de problemas relacionados ao throughput baixo ou ao aumento do atraso do consumidor na origem do aplicativo, consulte Solucionar problemas de desempenho.