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à.
Procedure consigliate e raccomandazioni generali per gli aggiornamenti delle applicazioni
-
Testa il nuovo job/runtime senza stato in un ambiente non di produzione prima di tentare un aggiornamento di produzione.
-
Valuta la possibilità di testare prima l'aggiornamento stateful 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 l'operatore che IDs hai impostato utilizzando il
uidmetodo rimanga lo stesso. Apache Flink consiglia vivamente l'assegnazione di elementi unici IDs agli operatori. Per ulteriori informazioni, consulta Assigning Operator IDs nella documentazionedi Apache Flink. Se non lo assegnate IDs ai vostri operatori, Flink li genera automaticamente. In tal caso, potrebbero dipendere dalla struttura del programma e, se modificate, causare problemi di compatibilità. Flink utilizza Operator IDs per abbinare lo stato nell'istantanea all'operatore. La modifica dell'operatore IDs 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.
-
