Esegui un servizio gestito per l'applicazione Apache Flink - Servizio gestito per Apache Flink
Identifica lo stato della candidatura e del lavoroEsegui carichi di lavoro in batch

Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Esegui un servizio gestito per l'applicazione Apache Flink

Questo argomento contiene informazioni sull'esecuzione di un servizio gestito per Apache Flink.

Quando si esegue l'applicazione di servizio gestito per Apache Flink, il servizio crea un processo Apache Flink. Un processo Apache Flink è il ciclo di vita dell'esecuzione dell'applicazione servizio gestito per Apache Flink. L'esecuzione del processo e le risorse che utilizza sono gestite dal Job Manager. Il Job Manager divide in attività l'esecuzione dell'applicazione. Ogni attività è gestita da un Task Manager. Quando si monitorano le prestazioni dell'applicazione, è possibile esaminare le prestazioni di ogni Task Manager o del Job Manager nel suo complesso.

Per informazioni sui job Apache Flink, consulta Jobs and Scheduling nella documentazione di Apache Flink.

Identifica lo stato della candidatura e del lavoro

Viene visualizzato lo status di esecuzione attuale dell’applicazione e del relativo processo:

  • Status dell'applicazione: lo status attuale che ne descrive la fase di esecuzione. Gli status dell’applicazione includono le seguenti opzioni:

    • Stati costanti dell'applicazione: l’applicazione in genere rimane in uno di questi stati finché non viene apportata una modifica dello stato:

      • READY: Un'applicazione nuova o interrotta rimane nello READY stato finché non viene eseguita.

      • RUNNING: un'applicazione che è stata avviata correttamente è nello RUNNING stato.

    • Stati transitori dell'applicazione: un'applicazione che si trova in uno di questi stati è in genere in fase di transizione a un altro stato. Se un'applicazione rimane in uno stato transitorio per un certo periodo di tempo, è possibile interromperla utilizzando l'StopApplicationazione con il Force parametro impostato su. true Questi status includono le seguenti opzioni:

      • STARTING:Si verifica dopo l'azione. StartApplication L'applicazione passa dallo status READY a RUNNING.

      • STOPPING:Si verifica dopo l'StopApplicationazione. L'applicazione passa dallo status RUNNING a READY.

      • DELETING:Si verifica dopo l'DeleteApplicationazione. L’applicazione è in fase di eliminazione.

      • UPDATING:Si verifica dopo l'UpdateApplicationazione. L'applicazione si sta aggiornando e tornerà allo status RUNNING o READY.

      • AUTOSCALING:L'applicazione ha la AutoScalingEnabled proprietà ParallelismConfigurationimpostata su e il servizio aumenta il parallelismo dell'applicazione. true Quando l'applicazione è in questo stato, l'unica API azione valida che è possibile utilizzare è l'StopApplicationazione con il Force parametro impostato su. true Per ulteriori informazioni sul dimensionamento automatico, consulta Usa il ridimensionamento automatico in Managed Service for Apache Flink.

      • FORCE_STOPPING:Si verifica dopo che l'StopApplicationazione è stata richiamata con il Force parametro impostato sutrue. L'applicazione è in fase di arresto forzato. L'applicazione passa dallo stato STARTING UPDATING, STOPPING o AUTOSCALING allo stato READY.

      • ROLLING_BACK:Si verifica dopo la chiamata RollbackApplicationdell'azione. È in corso il ripristino dell'applicazione a una versione precedente. L'applicazione passa dallo status UPDATING o AUTOSCALING a RUNNING.

      • MAINTENANCE: si verifica quando il servizio gestito per Apache Flink applica le patch all'applicazione. Per ulteriori informazioni, consulta Gestisci le attività di manutenzione per Managed Service for Apache Flink.

    Puoi controllare lo stato dell'applicazione utilizzando la console o utilizzando l'DescribeApplicationazione.

  • Status del processo: quando l’applicazione passa allo status RUNNING, viene visualizzato uno status del processo che ne descrive l’attuale fase di esecuzione. Un processo parte dallo status CREATED, quindi passa a RUNNING una volta iniziato. Se si verificano condizioni di errore, l'applicazione passa allo status seguente:

    • Per le applicazioni che utilizzano Apache Flink 1.11 e versioni successive, l'applicazione passa allo stato RESTARTING.

    • Per le applicazioni che utilizzano Apache Flink 1.8 e versioni precedenti, l'applicazione passa allo stato FAILING.

    L'applicazione passa quindi allo stato RESTARTING o FAILED, a seconda che il lavoro possa essere riavviato o meno.

    Puoi controllare lo stato del lavoro esaminando il CloudWatch registro della tua candidatura per eventuali modifiche allo stato.

Esegui carichi di lavoro in batch

Il servizio gestito per Apache Flink supporta l'esecuzione di carichi di lavoro in batch di Apache Flink. In un processo batch, quando un lavoro Apache Flink raggiunge FINISHEDlo stato, lo stato dell'applicazione Managed Service for Apache Flink viene impostato su. READY Per ulteriori informazioni sugli stati dei processi Flink, consulta Processi e pianificazione.