Atualize aplicativos usando atualizações de versão in-place do Apache Flink - Managed Service for Apache Flink
Antes de atualizar: atualize seu aplicativo Apache Flink

Anteriormente, o Amazon Managed Service for Apache Flink (Amazon MSF) 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á.

Atualize aplicativos usando atualizações de versão in-place do Apache Flink

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

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

Antes de atualizar: atualize seu aplicativo Apache Flink

Ao criar seus aplicativos Flink, você os empacota 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 for Apache Flink executa o trabalho no novo runtime do Flink que você selecionou. Talvez seja necessário atualizar seus aplicativos para obter compatibilidade com o runtime do Flink para o qual você deseja fazer o upgrade. Pode haver inconsistências entre as versões do Flink que causam falha na atualização da versão. Normalmente, 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 do 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 do Flink sobre como atualizar aplicativos com o estado. Consulte Atualização dos 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 as dependências e teste seus aplicativos localmente. Normalmente, essas dependências são:

    1. O runtime e a API do Flink.

    2. Conectores recomendados para o novo runtime do Flink. Você pode encontrá-los em Versões lançadas para o runtime específico para o qual deseja atualizar.

    3. Scala – O Apache Flink é independente de Scala, a partir do Flink 1.15. É necessário incluir as dependências do Scala que deseja usar no JAR do aplicativo.

  4. Crie um novo aplicativo JAR no zipfile e carregue no Amazon S3. Recomendamos que você use um nome diferente do JAR/zipfile anterior. Se precisar reverter, você usará essas informações.

  5. Se estiver executando aplicativos com estado, é altamente recomendável que você tire um snapshot do aplicativo atual. Isso permite fazer uma reversão com estado preservador se você encontrar problemas durante ou após a atualização.