Jalankan Layanan Terkelola untuk aplikasi Apache Flink - Layanan Terkelola untuk Apache Flink
Identifikasi lamaran dan status pekerjaanJalankan beban kerja batch

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.

Jalankan Layanan Terkelola untuk aplikasi Apache Flink

Topik ini berisi informasi tentang menjalankan Managed Service untuk Apache Flink.

Saat Anda menjalankan aplikasi Managed Service for Apache Flink, layanan akan membuat pekerjaan Apache Flink. Pekerjaan Apache Flink adalah siklus hidup eksekusi Layanan Terkelola untuk aplikasi Apache Flink Anda. Eksekusi tugas, dan sumber daya yang digunakannya, dikelola oleh Manajer Tugas. Manajer Tugas memisahkan eksekusi aplikasi ke dalam tugas-tugas. Setiap tugas dikelola oleh Manajer Tugas. Ketika Anda memantau performa aplikasi, Anda dapat memeriksa performa masing-masing Manajer Tugas, atau Manajer Tugas secara keseluruhan.

Untuk informasi tentang pekerjaan Apache Flink, lihat Pekerjaan dan Penjadwalan di Dokumentasi Apache Flink.

Identifikasi lamaran dan status pekerjaan

Aplikasi Anda dan tugas aplikasi memiliki status eksekusi saat ini:

  • Status aplikasi: Aplikasi Anda memiliki status saat ini yang menggambarkan fase eksekusi. Status aplikasi mencakup hal-hal berikut:

    • Status aplikasi stabil: Aplikasi Anda biasanya tetap berada dalam status ini hingga Anda membuat perubahan status:

      • READY: Aplikasi baru atau berhenti berada dalam READY status sampai Anda menjalankannya.

      • RUNNING: Aplikasi yang telah berhasil dimulai ada dalam RUNNING status.

    • Status aplikasi sementara: Aplikasi dalam status ini biasanya dalam proses transisi ke status lain. Jika aplikasi tetap dalam status sementara untuk jangka waktu yang lama, Anda dapat menghentikan aplikasi menggunakan StopApplicationtindakan dengan Force parameter yang disetel ke. true Status ini mencakup hal berikut:

      • STARTING:Terjadi setelah StartApplicationtindakan. Aplikasi ini bertransisi dari status READY ke RUNNING.

      • STOPPING:Terjadi setelah StopApplicationtindakan. Aplikasi ini bertransisi dari status RUNNING ke READY.

      • DELETING:Terjadi setelah DeleteApplicationtindakan. Aplikasi sedang dalam proses penghapusan.

      • UPDATING:Terjadi setelah UpdateApplicationtindakan. Aplikasi memperbarui, dan akan bertransisi kembali ke status RUNNING atau READY.

      • AUTOSCALING:Aplikasi ini memiliki AutoScalingEnabled properti ParallelismConfigurationset ketrue, dan layanan meningkatkan paralelisme aplikasi. Ketika aplikasi dalam status ini, satu-satunya API tindakan valid yang dapat Anda gunakan adalah StopApplicationtindakan dengan Force parameter yang disetel ketrue. Untuk informasi tentang penskalaan otomatis, lihat Gunakan penskalaan otomatis di Managed Service untuk Apache Flink.

      • FORCE_STOPPING:Terjadi setelah StopApplicationtindakan dipanggil dengan Force parameter diatur ketrue. Aplikasi sedang dalam proses penghentian paksa. Aplikasi bertransisi dari status STARTING, UPDATING, STOPPING, atau AUTOSCALING ke status READY.

      • ROLLING_BACK:Terjadi setelah RollbackApplicationtindakan dipanggil. Aplikasi sedang dalam proses dikembalikan ke versi sebelumnya. Aplikasi bertransisi dari status UPDATING atau AUTOSCALING ke status RUNNING.

      • MAINTENANCE:Terjadi saat Managed Service for Apache Flink menerapkan patch ke aplikasi Anda. Untuk informasi selengkapnya, lihat Mengelola tugas pemeliharaan untuk Managed Service untuk Apache Flink.

    Anda dapat memeriksa status aplikasi Anda menggunakan konsol, atau dengan menggunakan DescribeApplicationtindakan.

  • Job status (Status tugas): Saat aplikasi Anda berada dalam status RUNNING, tugas Anda memiliki status yang menggambarkan fase eksekusi saat ini. Tugas dimulai dalam status CREATED, lalu meneruskan ke status RUNNING ketika sudah dimulai. Jika kondisi kesalahan terjadi, aplikasi Anda memasuki status berikut:

    • Untuk aplikasi yang menggunakan Apache Flink 1.11 dan yang lebih baru, aplikasi Anda memasuki status RESTARTING.

    • Untuk aplikasi yang menggunakan Apache Flink 1.8 dan sebelumnya, aplikasi Anda memasuki status FAILING.

    Aplikasi selanjutnya meneruskan ke status RESTARTING atau FAILED, bergantung pada apakah tugas dapat dimulai ulang.

    Anda dapat memeriksa status pekerjaan dengan memeriksa CloudWatch log aplikasi Anda untuk perubahan status.

Jalankan beban kerja batch

Layanan Terkelola untuk Apache Flink mendukung menjalankan beban kerja batch Apache Flink. Dalam pekerjaan batch, ketika pekerjaan Apache Flink mencapai FINISHEDstatus, Layanan Terkelola untuk status aplikasi Apache Flink diatur ke. READY Untuk informasi selengkapnya tentang status pekerjaan Flink, lihat Pekerjaan dan Penjadwalan.