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 instruções detalhadas para atualizar seu aplicativo Amazon Managed Service para Apache Flink do Flink 1.x para o Flink 2.2. Esta é uma atualização de versão importante com mudanças significativas que exigem planejamento e testes cuidadosos.

Pré-requisitos

Antes de começar seu upgrade:

Entendendo seus caminhos de migração

Sua experiência de atualização depende da compatibilidade do seu aplicativo com o Flink 2.2. Entender 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, POJOs sem coleções)

Caminho 2: Incompatibilidades binárias

O que esperar:

Ideal para: Aplicativos que usam APIs removidas que são detectadas durante a inicialização da tarefa do Flink

Caminho 3: estado de aplicativo incompatível

O que esperar:

Ideal para: Aplicativos com incompatibilidades de serialização de estado (POJOs com coleções, determinado estado) Kryo-serialized

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

Auto-rollback permite que o Amazon Managed Service para Apache Flink reverta automaticamente para a versão anterior se a atualização falhar.

Verifique o status de 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 habilitada)

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 essa 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 instantâneo

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 UpdateApplication açã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 for Apache Flink valida a compatibilidade entre a versão de tempo de execução original e a versão de tempo de execução de destino. Essa verificação de compatibilidade é executada quando você executa UpdateApplication enquanto estiver no RUNNING estado ou no próximo, StartApplication se você fizer o upgrade enquanto estiver 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"
                }
            }
        }
    }'

Atualize 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 checkpoint:

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, reverta 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 reverterá 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 Suporte.