View a markdown version of this page

Procedure consigliate e consigli generali per gli aggiornamenti delle applicazioni - Servizio gestito 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à.

Procedure consigliate e consigli generali per gli aggiornamenti delle applicazioni

  • Prova la nuova versione job/runtime senza stato in un ambiente non di produzione prima di tentare un aggiornamento in produzione.

  • Valuta la possibilità di testare prima lo stateful upgrade con un'applicazione non di produzione.

  • Assicurati che il tuo nuovo job graph abbia uno stato compatibile con l'istantanea che utilizzerai per avviare l'applicazione aggiornata.

    • Assicurati che i tipi memorizzati negli stati dell'operatore rimangano gli stessi. Se il tipo è cambiato, Apache Flink non può ripristinare lo stato dell'operatore.

    • Assicurati che gli ID operatore impostati utilizzando il uid metodo rimangano gli stessi. Apache Flink consiglia vivamente di assegnare ID univoci agli operatori. Per ulteriori informazioni, consulta Assegnazione degli ID operatore nella documentazione di Apache Flink.

      Se non assegnate ID ai vostri operatori, Flink li genera automaticamente. In tal caso, potrebbero dipendere dalla struttura del programma e, se modificati, causare problemi di compatibilità. Flink utilizza gli ID degli operatori per abbinare lo stato nell'istantanea all'operatore. La modifica degli ID operatore comporta il mancato avvio dell'applicazione, l'eliminazione dello stato memorizzato nell'istantanea e l'avvio del nuovo operatore senza stato.

    • Non modificate la chiave utilizzata per memorizzare lo stato della chiave.

    • Non modificate il tipo di input degli operatori statici come window o join. Ciò modifica implicitamente il tipo di stato interno dell'operatore, causando un'incompatibilità di stato.