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á.
FlinkKafkaConsumer problema com stop with savepoint
Ao usar o legado, FlinkKafkaConsumer existe a possibilidade de seu aplicativo ficar preso STOPPING ou UPDATINGSCALING, se você tiver os instantâneos do sistema habilitados. Não há nenhuma correção publicada disponível para esse problema
Se você estiver usando o FlinkKafkaConsumer com instantâneos habilitados, existe a possibilidade de que, quando a tarefa do Flink processe uma parada com uma API solicitação de ponto de salvamento, ela falhe com um erro FlinkKafkaConsumer de tempo de execução relatando a. ClosedException Sob essas condições, o aplicativo Flink fica preso, manifestando-se como pontos de verificação com falha.
