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 Studio Runtime
Questa sezione contiene informazioni su come aggiornare il notebook Studio Runtime. Ti consigliamo di eseguire sempre l'aggiornamento all'ultima versione supportata di Studio Runtime.
Aggiorna il tuo notebook a un nuovo Studio Runtime
A seconda di come utilizzi Studio, i passaggi per aggiornare il tuo Runtime sono diversi. Seleziona l'opzione più adatta al tuo caso d'uso.
Se stai usando SQL o Python senza dipendenze esterne, usa il seguente processo di aggiornamento del Runtime. Ti consigliamo di eseguire l'aggiornamento all'ultima versione di Runtime. Il processo di aggiornamento è lo stesso, indipendentemente dalla versione di Runtime da cui si esegue l'aggiornamento.
-
Crea un nuovo notebook Studio utilizzando la versione più recente del Runtime.
-
Copia e incolla il codice di ogni nota dal vecchio taccuino al nuovo taccuino.
-
Nel nuovo taccuino, modifica il codice per renderlo compatibile con qualsiasi funzionalità di Apache Flink modificata rispetto alla versione precedente.
-
Esegui il nuovo notebook. Apri il taccuino ed eseguilo nota per nota, in sequenza, e verifica se funziona.
-
Apporta le modifiche necessarie al codice.
-
Arresta il nuovo notebook.
-
-
Se hai distribuito il vecchio notebook come applicazione:
-
Implementa il nuovo notebook come nuova applicazione separata.
-
Arresta la vecchia applicazione.
-
Esegui la nuova applicazione senza istantanea.
-
-
Arresta il vecchio notebook se è in esecuzione. Avvia il nuovo notebook, se necessario, per un uso interattivo.
Flusso di processo per l'aggiornamento senza dipendenze esterne
Segui questo processo se utilizzi SQL o Python e utilizzi dipendenze esterne come connettori o artefatti personalizzati, come funzioni definite dall'utente implementate in Python o Java. Ti consigliamo di eseguire l'aggiornamento alla versione più recente del Runtime. Il processo è lo stesso, indipendentemente dalla versione di Runtime da cui si esegue l'aggiornamento.
-
Crea un nuovo notebook Studio utilizzando la versione più recente del Runtime.
-
Copia e incolla il codice di ogni nota dal vecchio taccuino al nuovo taccuino.
-
Aggiorna le dipendenze esterne e gli artefatti personalizzati.
-
Cerca nuovi connettori compatibili con la versione Apache Flink del nuovo Runtime. Fate riferimento alla Tabella e SQL connettori
nella documentazione di Apache Flink per trovare i connettori corretti per la versione Flink. -
Aggiorna il codice delle funzioni definite dall'utente in modo che corrisponda alle modifiche in Apache Flink API e a qualsiasi Python o JAR dipendenza utilizzata dalle funzioni definite dall'utente. Reimpacchetta il tuo artefatto personalizzato aggiornato.
-
Aggiungi questi nuovi connettori e artefatti al nuovo notebook.
-
-
Nel nuovo notebook, modifica il codice per renderlo compatibile con qualsiasi funzionalità di Apache Flink modificata rispetto alla versione precedente.
-
Esegui il nuovo notebook. Apri il taccuino ed eseguilo nota per nota, in sequenza, e verifica se funziona.
-
Apporta le modifiche necessarie al codice.
-
Arresta il nuovo notebook.
-
-
Se hai distribuito il vecchio notebook come applicazione:
-
Implementa il nuovo notebook come nuova applicazione separata.
-
Arresta la vecchia applicazione.
-
Esegui la nuova applicazione senza istantanea.
-
-
Arresta il vecchio notebook se è in esecuzione. Avvia il nuovo notebook, se necessario, per un uso interattivo.
Flusso di processo per l'aggiornamento con dipendenze esterne
