Memutakhirkan Runtime Studio - Layanan Terkelola untuk Apache Flink
Memutakhirkan notebook Anda ke Studio Runtime baru

Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Memutakhirkan Runtime Studio

Bagian ini berisi informasi tentang cara memutakhirkan Runtime notebook Studio Anda. Kami menyarankan Anda untuk selalu meningkatkan ke Studio Runtime terbaru yang didukung.

Memutakhirkan notebook Anda ke Studio Runtime baru

Bergantung pada cara Anda menggunakan Studio, langkah-langkah untuk meningkatkan Runtime Anda berbeda. Pilih opsi yang sesuai dengan kasus penggunaan Anda.

Jika Anda menggunakan SQL atau Python tanpa dependensi eksternal, gunakan proses upgrade Runtime berikut. Kami menyarankan Anda meningkatkan ke versi Runtime terbaru. Proses pemutakhiran sama, tanpa belakang dari versi Runtime yang Anda tingkatkan.

  1. Buat notebook Studio baru menggunakan Runtime terbaru.

  2. Salin dan tempel kode setiap catatan dari buku catatan lama ke buku catatan baru.

  3. Di notebook baru, sesuaikan kode agar kompatibel dengan fitur Apache Flink apa pun yang telah berubah dari versi sebelumnya.

    • Jalankan notebook baru. Buka notebook dan jalankan catatan demi catatan, secara berurutan, dan uji apakah itu berfungsi.

    • Buat perubahan yang diperlukan pada kode.

    • Hentikan buku catatan baru.

  4. Jika Anda telah menggunakan notebook lama sebagai aplikasi:

    • Terapkan notebook baru sebagai aplikasi baru yang terpisah.

    • Hentikan aplikasi lama.

    • Jalankan aplikasi baru tanpa snapshot.

  5. Hentikan notebook lama jika sedang berjalan. Mulai notebook baru, sesuai kebutuhan, untuk penggunaan interaktif.

Alur proses untuk upgrade tanpa dependensi eksternal

Diagram berikut menunjukkan alur kerja yang disarankan untuk meng-upgrade notebook Anda tanpa dependensi eksternal.

Ikuti proses ini jika Anda menggunakan SQL atau Python dan menggunakan dependensi eksternal seperti konektor atau artefak khusus, seperti fungsi yang ditentukan pengguna yang diimplementasikan dalam Python atau Java. Kami menyarankan Anda meningkatkan ke Runtime terbaru. Prosesnya sama, terlepas dari versi Runtime yang Anda tingkatkan.

  1. Buat notebook Studio baru menggunakan Runtime terbaru.

  2. Salin dan tempel kode setiap catatan dari buku catatan lama ke buku catatan baru.

  3. Perbarui dependensi eksternal dan artefak khusus.

    • Cari konektor baru yang kompatibel dengan versi Apache Flink dari Runtime baru. Lihat Konektor Tabel & SQL dalam dokumentasi Apache Flink untuk menemukan konektor yang benar untuk versi Flink.

    • Perbarui kode fungsi yang ditentukan pengguna agar sesuai dengan perubahan di Apache Flink API, dan dependensi Python atau JAR apa pun yang digunakan oleh fungsi yang ditentukan pengguna. Kemas ulang artefak kustom Anda yang diperbarui.

    • Tambahkan konektor dan artefak baru ini ke notebook baru.

  4. Di notebook baru, sesuaikan kode agar kompatibel dengan fitur Apache Flink apa pun yang telah berubah dari versi sebelumnya.

    • Jalankan notebook baru. Buka notebook dan jalankan catatan demi catatan, secara berurutan, dan uji apakah itu berfungsi.

    • Buat perubahan yang diperlukan pada kode.

    • Hentikan buku catatan baru.

  5. Jika Anda telah menggunakan notebook lama sebagai aplikasi:

    • Terapkan notebook baru sebagai aplikasi baru yang terpisah.

    • Hentikan aplikasi lama.

    • Jalankan aplikasi baru tanpa snapshot.

  6. Hentikan notebook lama jika sedang berjalan. Mulai notebook baru, sesuai kebutuhan, untuk penggunaan interaktif.

Alur proses untuk meningkatkan dengan dependensi eksternal

Diagram berikut mewakili alur kerja yang disarankan untuk meng-upgrade notebook Anda dengan dependensi eksternal..