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

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

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 READY status até que você o execute.

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

    • 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 API ação 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 lotes, quando um trabalho do Apache Flink atinge o FINISHEDstatus, o status do aplicativo Managed Service for Apache Flink é definido como. READY Para obter mais informações sobre os status de trabalho do Flink, consulte Trabalhos e programação.