Atualize aplicativos usando atualizações de versão in-loco para o Apache Flink - Managed Service for Apache Flink
Antes da atualização: atualize seu aplicativo Apache Flink

O Amazon Managed Service para Apache Flink (Amazon MSF) era conhecido anteriormente 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á.

Atualize aplicativos usando atualizações de versão in-loco para o Apache Flink

Antes de começar, recomendamos que você assista a este vídeo: Atualizações de versão in-loco.

Para realizar atualizações de versão in-loco para o Apache Flink, você pode usar o AWS CLI, AWS CloudFormation, AWS SDK ou o. AWS Management Console Você pode usar esse recurso com qualquer aplicativo existente que você usa com o Managed Service for Apache Flink em um estado READY ouRUNNING. Ele usa a UpdateApplication API para adicionar a capacidade de alterar o tempo de execução do Flink.

Antes da atualização: atualize seu aplicativo Apache Flink

Ao escrever seus aplicativos Flink, você os agrupa com suas dependências em um JAR de aplicativo e carrega o JAR no seu bucket do Amazon S3. A partir daí, o Amazon Managed Service para Apache Flink executa o trabalho no novo tempo de execução do Flink que você selecionou. Talvez seja necessário atualizar seus aplicativos para obter compatibilidade com o tempo de execução do Flink para o qual você deseja fazer o upgrade. Pode haver inconsistências entre as versões do Flink que fazem com que a atualização da versão falhe. Geralmente, isso ocorre com conectores para fontes (entrada) ou destinos (coletores, saída) e dependências do Scala. O Flink 1.15 e versões posteriores no Managed Service for Apache Flink são independentes de Scala, e seu JAR deve conter a versão do Scala que você planeja usar.

Para atualizar seu aplicativo

  1. Leia os conselhos da comunidade Flink sobre como atualizar aplicativos com o estado. Consulte Atualização de aplicativos e versões do Flink.

  2. Leia a lista de problemas e limitações conhecidos. Consulte Precauções e problemas conhecidos com atualizações de aplicativos.

  3. Atualize suas dependências e teste seus aplicativos localmente. Essas dependências normalmente são:

    1. O tempo de execução e a API do Flink.

    2. Conectores recomendados para o novo tempo de execução do Flink. Você pode encontrá-los nas versões Release para o tempo de execução específico para o qual deseja atualizar.

    3. Scala — O Apache Flink é independente de Scala, começando com e incluindo o Flink 1.15. Você deve incluir as dependências do Scala que deseja usar no JAR do seu aplicativo.

  4. Crie um novo aplicativo JAR no arquivo zip e faça o upload para o Amazon S3. Recomendamos que você use um nome diferente do arquivo JAR/ZIP anterior. Se precisar reverter, você usará essas informações.

  5. Se você estiver executando aplicativos com estado, é altamente recomendável que você tire um instantâneo do seu aplicativo atual. Isso permite reverter de forma contínua se você encontrar problemas durante ou após a atualização.