Execute um serviço gerenciado para o aplicativo Apache Flink - Managed Service for Apache Flink
Identifique a candidatura e o status do trabalhoExecute cargas de trabalho em lote

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

Execute um serviço gerenciado para o aplicativo Apache Flink

Este tópico contém informações sobre como executar o Managed Service for Apache Flink.

Quando você executa o seu Managed Service for Apache Flink, o serviço cria um trabalho do Apache Flink. Um trabalho do Apache Flink é o ciclo de vida de execução do seu aplicativo Managed Service for Apache Flink. A execução do trabalho e os recursos que ele usa são gerenciados pelo Job Manager. O Job Manager divide a execução do aplicativo em tarefas. Cada tarefa é gerenciada por um gerenciador de tarefas. Ao monitorar o desempenho do seu aplicativo, você pode examinar o desempenho de cada gerenciador de tarefas ou do Job Manager como um todo.

Para obter informações sobre trabalhos do Apache Flink, consulte Trabalhos e agendamento na documentação do Apache Flink.

Identifique a candidatura e o status do trabalho

Tanto seu aplicativo quanto o trabalho do aplicativo têm um status de execução atual:

  • Status do aplicativo: seu aplicativo tem um status atual que descreve a sua fase de execução. Os status do aplicativo incluem o seguinte:

    • Status de aplicativo estacionário: seu aplicativo normalmente permanece nesses status até que você faça uma alteração de status:

      • READY: Um aplicativo novo ou interrompido está no status PRONTO até que você o execute.

      • RUNNING: Um aplicativo que foi iniciado com sucesso está no status EXECUTANDO.

    • Status transitórios de aplicativos: Um aplicativo nesses status normalmente está em processo de transição para outro status. Se um aplicativo permanecer em um status transitório por um período de tempo, você poderá interromper o aplicativo usando a StopApplicationação com o Force parâmetro definido como. true Esses status incluem o seguinte:

      • STARTING:Ocorre após a StartApplicationação. O aplicativo está passando do status READY para RUNNING.

      • STOPPING:Ocorre após a StopApplicationação. O aplicativo está passando do status RUNNING para READY.

      • DELETING:Ocorre após a DeleteApplicationação. O aplicativo está em processo de ser excluído.

      • UPDATING:Ocorre após a UpdateApplicationação. O aplicativo está sendo atualizado e voltará ao status RUNNING ou READY.

      • AUTOSCALING:O aplicativo tem a AutoScalingEnabled propriedade de ParallelismConfigurationdefinir comotrue, e o serviço está aumentando o paralelismo do aplicativo. Quando o aplicativo está nesse status, a única ação de API válida que você pode usar é a StopApplicationação com o Force parâmetro definido comotrue. Para obter mais informações sobre escalabilidade, consulte Use o escalonamento automático no Managed Service para Apache Flink.

      • FORCE_STOPPING:Ocorre depois que a StopApplicationação é chamada com o Force parâmetro definido comotrue. O aplicativo está em processo de ser interrompido à força. O aplicativo faz a transição do status STARTING, UPDATING, STOPPING, ou AUTOSCALING para o statusREADY.

      • ROLLING_BACK:Ocorre depois que a RollbackApplicationação é chamada. O aplicativo está em processo de ser revertido para uma versão anterior. O aplicativo faz a transição do status UPDATING ou AUTOSCALING para o status RUNNING.

      • MAINTENANCE: Ocorre enquanto o Managed Service for Apache Flink aplica patches ao seu aplicativo. Para obter mais informações, consulte Gerencie tarefas de manutenção do Managed Service for Apache Flink.

    Você pode verificar o status do seu aplicativo usando o console ou usando a DescribeApplicationação.

  • Status do trabalho: quando seu aplicativo está no status RUNNING, o seu trabalho tem um status que descreve a fase de execução atual. Um trabalho começa no status CREATED e, em seguida, passa para o status RUNNING quando é iniciado. Se ocorrerem condições de erro, o seu aplicativo entrará no seguinte status:

    • Para aplicativos que usam o Apache Flink 1.11 e versões posteriores, seu aplicativo entra no status RESTARTING.

    • Para aplicativos que usam o Apache Flink 1.8 e versões anteriores, seu aplicativo entra no status FAILING.

    Em seguida, o aplicativo passa para o status RESTARTING ou FAILED, dependendo se o trabalho pode ser reiniciado.

    Você pode verificar o status do trabalho examinando o CloudWatch registro de sua inscrição em busca de alterações de status.

Execute cargas de trabalho em lote

O Managed Service for Apache Flink suporta a execução de workloads em batch do Apache Flink. Em um trabalho em lote, quando um trabalho do Apache Flink atinge o status FINALIZADO, o status do aplicativo Managed Service for Apache Flink é definido como PRONTO. Para obter mais informações sobre os status de trabalho do Flink, consulte Trabalhos e programação.