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á.

Atualizando para o Flink 2.2: guia completo

Este guia fornece step-by-step instruções para atualizar seu aplicativo Amazon Managed Service for Apache Flink do Flink 1.x para o Flink 2.2. Esta é uma atualização de versão importante com alterações significativas que exigem planejamento e testes cuidadosos.

Pré-requisitos

Antes de começar sua atualização:

Entendendo seus caminhos de migração

Sua experiência de atualização depende da compatibilidade do seu aplicativo com o Flink 2.2. Compreender esses caminhos ajuda você a se preparar adequadamente e definir expectativas realistas.

Caminho 1: binário compatível e estado do aplicativo

O que esperar:

Ideal para: aplicativos sem estado ou aplicativos que usam serialização compatível (Avro, esquemas Protobuf compatíveis, sem coleções) POJOs

Caminho 2: incompatibilidades binárias

O que esperar:

Ideal para: aplicativos removidos APIs que são detectados durante a inicialização do trabalho do Flink

Caminho 3: estado incompatível do aplicativo

O que esperar:

Ideal para: aplicativos com incompatibilidades de serialização de estado (POJOs com coleções, determinado estado serializado do Kryo)

Fase 1: Preparação

Atualizar o código do aplicativo

Atualize o código do seu aplicativo para ser compatível com o Flink 2.2:

Carregar código de aplicativo atualizado

Fase 2: ativar a reversão automática

A reversão automática permite que o Amazon Managed Service para Apache Flink reverta automaticamente para a versão anterior se a atualização falhar.

Verifique o status da reversão automática

Console de gerenciamento da AWS:

AWS CLI:

aws kinesisanalyticsv2 describe-application \
    --application-name MyApplication \
    --query 'ApplicationDetail.ApplicationConfigurationDescription.ApplicationSystemRollbackConfigurationDescription.RollbackEnabled'

Ativar a reversão automática (se não estiver ativada)

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --application-configuration-update '{
        "ApplicationSystemRollbackConfigurationUpdate": {
            "RollbackEnabledUpdate": true
        }
    }'

Fase 3: tirar uma foto (opcional)

Se os instantâneos automáticos estiverem habilitados para seu aplicativo, você poderá pular esta etapa, caso contrário, tire um instantâneo do seu aplicativo para salvar o estado do seu aplicativo antes da atualização.

Tire um instantâneo do aplicativo em execução

Console de gerenciamento da AWS:

AWS CLI:

aws kinesisanalyticsv2 create-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

Verificar a criação do snapshot

aws kinesisanalyticsv2 describe-application-snapshot \
    --application-name MyApplication \
    --snapshot-name pre-flink-2.2-upgrade

Espere até que SnapshotStatus seja READY antes de continuar.

Fase 4: Atualizar o aplicativo

Você pode atualizar seu aplicativo Flink usando a UpdateApplicationação.

Você pode chamar a API UpdateApplication de várias maneiras:

Você pode realizar a atualização enquanto o aplicativo estiver no estado RUNNING ou enquanto o aplicativo estiver parado no estado READY. O Amazon Managed Service para Apache Flink valida a compatibilidade entre a versão original do tempo de execução e a versão do tempo de execução de destino. Essa verificação de compatibilidade é executada quando você executa UpdateApplication enquanto está no RUNNING estado ou na próxima, StartApplication se você atualiza enquanto está no READY estado.

Atualização do estado RUNNING

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

Atualização do estado READY

aws kinesisanalyticsv2 update-application \
    --application-name MyApplication \
    --current-application-version-id <version-id> \
    --runtime-environment-update FLINK-2_2 \
    --application-configuration-update '{
        "ApplicationCodeConfigurationUpdate": {
            "CodeContentUpdate": {
                "S3ContentLocationUpdate": {
                    "FileKeyUpdate": "my-app-flink-2.2.jar"
                }
            }
        }
    }'

Fase 5: atualização do monitor

Verificação de compatibilidade

Monitore a integridade do aplicativo

Estado do aplicativo:

Além disso, monitore essas métricas em CloudWatch:

Métrica de reinicialização:

Métricas do ponto de verificação:

Fase 6: Validar o comportamento do aplicativo

Depois que o aplicativo estiver sendo executado no Flink 2.2:

Validação funcional

Validação de desempenho

Corra por mais de 24 horas

Permita que o aplicativo seja executado por pelo menos 24 horas em produção para garantir:

Fase 7: procedimentos de reversão

Se a atualização falhar ou o aplicativo estiver em execução, mas não estiver íntegro, volte para a versão anterior.

Reversão automática

Se a reversão automática estiver ativada e a atualização falhar durante a inicialização, o Amazon Managed Service para Apache Flink reverte automaticamente para a versão anterior.

Reversão manual

Se o aplicativo estiver em execução, mas não estiver íntegro, use a RollbackApplication API:

Console de gerenciamento da AWS:

AWS CLI:

aws kinesisanalyticsv2 rollback-application \
    --application-name MyApplication \
    --current-application-version-id <version-id>

O que acontece durante a reversão:

Próximas etapas

Em caso de dúvidas ou problemas durante a atualização, consulte Solucionar problemas do Managed Service for Apache Flink ou entre em contato com o AWS Support.