Execute um aplicativo Managed Service for Apache Flink - Managed Service for Apache Flink
Identifique o status do aplicativo e do trabalhoExecute workloads em lote

Anteriormente, o Amazon Managed Service for Apache Flink (Amazon MSF) era conhecido como Amazon Kinesis Data Analytics for Apache Flink.

Execute um aplicativo Managed Service for 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 os trabalhos do Apache Flink, consulte Trabalhos e programação na documentação do Apache Flink.

Identifique o status do aplicativo e 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 ação StopApplication com o Force parâmetro definido como true. Esses status incluem o seguinte:

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

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

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

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

      • AUTOSCALING:O aplicativo tem a propriedade AutoScalingEnabled do ParallelismConfiguration definida como true, 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 ação StopApplication com o parâmetro Force definido como true. Para obter mais informações sobre escalabilidade, consulte Use a escalabilidade automática no Managed Service for Apache Flink.

      • FORCE_STOPPING: Ocorre depois que a ação StopApplication é chamada com o Force parâmetro definido como true. 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 ação RollbackApplication é 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 as tarefas de manutenção do Managed Service for Apache Flink..

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

  • 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 log do CloudWatch do seu aplicativo em busca de alterações de status.

Execute workloads 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.