Aggiorna le applicazioni utilizzando aggiornamenti di versione in loco per Apache Flink - Servizio gestito per Apache Flink
Prima dell'aggiornamento: aggiorna la tua applicazione Apache Flink

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

Aggiorna le applicazioni utilizzando aggiornamenti di versione in loco per Apache Flink

Prima di iniziare, ti consigliamo di guardare questo video: Aggiornamenti delle versioni in loco.

Per eseguire aggiornamenti di versione sul posto per Apache Flink, puoi usare,, o. AWS CLI AWS CloudFormation AWS SDK AWS Management ConsoleÈ possibile utilizzare questa funzionalità con qualsiasi applicazione esistente utilizzata con Managed Service for Apache Flink in uno stato or. READY RUNNING Utilizza il UpdateApplication API per aggiungere la possibilità di modificare il runtime di Flink.

Prima dell'aggiornamento: aggiorna la tua applicazione Apache Flink

Quando scrivi le tue applicazioni Flink, le raggruppi con le relative dipendenze in un'applicazione JAR e le carichi nel tuo bucket JAR Amazon S3. Da lì, Amazon Managed Service for Apache Flink esegue il job nel nuovo runtime Flink che hai selezionato. Potrebbe essere necessario aggiornare le applicazioni per ottenere la compatibilità con il runtime Flink a cui desideri eseguire l'aggiornamento. Possono esserci delle incongruenze tra le versioni di Flink che impediscono l'aggiornamento della versione. Più comunemente, ciò avverrà con connettori per sorgenti (ingresso) o destinazioni (lavandini, uscite) e dipendenze di Scala. Flink 1.15 e le versioni successive di Managed Service for Apache Flink sono indipendenti dalla scala e devono contenere la versione di Scala che intendi utilizzare. JAR

Per aggiornare l'applicazione

  1. Leggi i consigli della community di Flink sull'aggiornamento delle applicazioni con state. Vedi Aggiornamento delle applicazioni e delle versioni di Flink.

  2. Leggi l'elenco dei problemi e delle limitazioni più comuni. Per informazioni, consulta Precauzioni e problemi noti relativi agli aggiornamenti delle applicazioni.

  3. Aggiorna le tue dipendenze e testa le tue applicazioni localmente. Queste dipendenze sono in genere:

    1. Il runtime di Flink e. API

    2. Connettori consigliati per il nuovo runtime Flink. Puoi trovarli nelle versioni Release per il runtime specifico a cui desideri eseguire l'aggiornamento.

    3. Scala — Apache Flink è indipendente dalla scala a partire da Flink 1.15 incluso. È necessario includere le dipendenze di Scala che si desidera utilizzare nell'applicazione. JAR

  4. Crea una nuova applicazione JAR su zipfile e caricala su Amazon S3. Ti consigliamo di utilizzare un nome diverso dal precedente /zipfile. JAR Se devi eseguire il rollback, utilizzerai queste informazioni.

  5. Se esegui applicazioni con stato, ti consigliamo vivamente di scattare un'istantanea dell'applicazione corrente. In questo modo è possibile eseguire il rollback in modalità statefully in caso di problemi durante o dopo l'aggiornamento.