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

Configurações do Apache Flink

O Managed Service for Apache Flink é uma implementação da estrutura Apache Flink. O Managed Service for Apache Flink usa os valores padrão descritos nesta seção. Alguns desses valores podem ser definidos pelos aplicativos Managed Service for Apache Flink em código, e outros não podem ser alterados.

Use os links desta seção para saber mais sobre as configurações do Apache Flink e quais são modificáveis.

Configuração do Apache Flink

O Managed Service for Apache Flink fornece uma configuração padrão do Flink que consiste em valores recomendados pelo Apache Flink para a maioria das propriedades e alguns baseados em perfis comuns de aplicativos. Para obter mais informações sobre a configuração do Flink, consulte Configuração. A configuração padrão fornecida pelo serviço funciona para a maioria dos aplicativos. No entanto, para ajustar as propriedades de configuração do Flink para melhorar o desempenho de determinados aplicativos com alto paralelismo, alto uso de memória e estado, ou habilitar novos recursos de depuração no Apache Flink, você poderá alterar determinadas propriedades solicitando um caso de suporte. Para obter mais informações, consulte o Support Center do AWS. Você pode verificar a configuração atual do seu aplicativo usando o painel do Apache Flink.

Estado de backend

O Managed Service for Apache Flink armazena dados transitórios em um estado de backend. O Managed Service for Apache Flink usa o RocksDBStateBackend. Chamar setStateBackend para definir um backend diferente não tem efeito.

Habilitamos os seguintes recursos no estado de backend:

Para obter mais informações sobre estados de backend, consulte State Backends na documentação do Apache Flink.

Pontos de verificação

O Managed Service for Apache Flink usa uma configuração de ponto de verificação padrão com os seguintes valores. É possível alterar alguns desses valores usando o CheckpointConfiguration. Você deve definir CheckpointConfiguration.ConfigurationType para CUSTOM que o Managed Service for Apache Flink use valores de pontos de verificação modificados.

Salvamento

Por padrão, ao restaurar a partir de um ponto de salvamento, a operação de retomada tentará mapear todo o estado do ponto de salvamento de volta até o programa com o qual você está restaurando. Se você descartar um operador, por padrão, a restauração a partir de um ponto de salvamento que tenha dados que correspondam ao operador ausente falhará. Você pode permitir que a operação seja bem-sucedida definindo o parâmetro allowNonRestoredState da FlinkRunConfiguration do aplicativo como true. Isso permitirá que a operação de retomada ignore um estado que não possa ser mapeado para o novo programa.

Para obter mais informações, consulte Allowing Non-Restored State (Permitir estado não restaurado) na documentação do Apache Flink.

Tamanhos de heap

O Managed Service for Apache Flink aloca cada KPU 3 GiB do heap da JVM e reserva 1 GiB para alocações de código nativo. Para obter informações sobre como aumentar a capacidade do seu aplicativo, consulte Implemente a escalabilidade de aplicativos no Managed Service for Apache Flink.

Para obter mais informações sobre tamanhos de heap da JVM, consulte Configuração na documentação do Apache Flink.

Diminuição do buffer

A diminuição do buffer pode ajudar aplicativos com alta contrapressão. Se o seu aplicativo apresentar falhas nos pontos de verificação/salvamento, habilitar esse recurso pode ser útil. Para fazer isso, solicite um caso de suporte.

Para obter mais informações, consulte The Buffer Debloating Mechanism na documentação do Apache Flink.