

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

# Buat Layanan Terkelola untuk aplikasi Apache Flink
<a name="how-creating-apps"></a>

Topik ini berisi informasi tentang membuat Layanan Terkelola untuk aplikasi Apache Flink.

**Topics**
+ [Bangun Layanan Terkelola Anda untuk kode aplikasi Apache Flink](#how-creating-apps-building)
+ [Buat Layanan Terkelola Anda untuk aplikasi Apache Flink](#how-creating-apps-creating)
+ [Gunakan kunci yang dikelola pelanggan](#how-creating-apps-use-cmk)
+ [Mulai Layanan Terkelola Anda untuk aplikasi Apache Flink](#how-creating-apps-starting)
+ [Verifikasi Layanan Terkelola Anda untuk aplikasi Apache Flink](#how-creating-apps-verifying)
+ [Aktifkan rollback sistem untuk Layanan Terkelola Anda untuk aplikasi Apache Flink](how-system-rollbacks.md)

## Bangun Layanan Terkelola Anda untuk kode aplikasi Apache Flink
<a name="how-creating-apps-building"></a>

Bagian ini menjelaskan komponen yang Anda gunakan untuk membangun kode aplikasi untuk Layanan Terkelola untuk aplikasi Apache Flink Anda. 

Sebaiknya gunakan versi terbaru Apache Flink yang didukung untuk kode aplikasi Anda. Untuk informasi tentang memutakhirkan Layanan Terkelola untuk aplikasi Apache Flink, lihat. [Gunakan upgrade versi di tempat untuk Apache Flink](how-in-place-version-upgrades.md) 

Anda membangun kode aplikasi Anda menggunakan [Apache Maven](https://maven.apache.org/). Proyek Apache Maven menggunakan file `pom.xml` untuk menentukan versi komponen yang digunakan. 

**catatan**  
Layanan Terkelola untuk Apache Flink mendukung file JAR hingga ukuran 512 MB. Jika Anda menggunakan file JAR lebih besar dari ini, aplikasi Anda akan gagal dimulai.

Aplikasi sekarang dapat menggunakan Java API dari versi Scala apa pun. Anda harus menggabungkan pustaka standar Scala pilihan Anda ke dalam aplikasi Scala Anda.

Untuk informasi tentang membuat Layanan Terkelola untuk aplikasi Apache Flink yang menggunakan **Apache Beam**, lihat. [Gunakan Apache Beam dengan Managed Service untuk aplikasi Apache Flink](how-creating-apps-beam.md)

### Tentukan versi Apache Flink aplikasi Anda
<a name="how-creating-apps-building-flink"></a>

Saat menggunakan Managed Service for Apache Flink Runtime versi 1.1.0 dan yang lebih baru, Anda menentukan versi Apache Flink yang digunakan aplikasi Anda saat Anda mengkompilasi aplikasi Anda. Anda memberikan versi Apache Flink dengan parameter. `-Dflink.version` Misalnya, jika Anda menggunakan Apache Flink 2.2.0, berikan yang berikut ini:

```
mvn package -Dflink.version=2.2.0
```

Untuk membangun aplikasi dengan versi Apache Flink sebelumnya, lihat. [Versi sebelumnya](earlier.md)

## Buat Layanan Terkelola Anda untuk aplikasi Apache Flink
<a name="how-creating-apps-creating"></a>

Setelah membuat kode aplikasi, lakukan hal berikut untuk membuat aplikasi Managed Service for Apache Flink (Amazon MSF):
+ **Unggah kode Aplikasi Anda**: Unggah kode aplikasi Anda ke bucket Amazon S3. Anda menentukan nama bucket S3 dan nama objek kode aplikasi Anda ketika membuat aplikasi Anda. Untuk tutorial yang menunjukkan cara mengunggah kode aplikasi Anda, lihat [Tutorial: Mulai menggunakan DataStream API di Managed Service untuk Apache Flink](getting-started.md) tutorialnya.
+ **Buat Layanan Terkelola untuk aplikasi Apache Flink** Anda: Gunakan salah satu metode berikut untuk membuat aplikasi MSF Amazon Anda:
**catatan**  
Amazon MSF mengenkripsi aplikasi Anda secara default menggunakan. Kunci milik AWS Anda juga dapat membuat aplikasi baru menggunakan kunci yang dikelola AWS KMS pelanggan (CMK) untuk membuat, memiliki, dan mengelola kunci Anda sendiri. Untuk informasi tentang CMK, lihat[Manajemen kunci di Amazon Managed Service untuk Apache Flink](key-management-flink.md).
  + **Buat aplikasi Amazon MSF Anda menggunakan AWS konsol:** Anda dapat membuat dan mengonfigurasi aplikasi Anda menggunakan AWS konsol. 

    Saat Anda membuat aplikasi menggunakan konsol, sumber daya dependen aplikasi Anda (seperti aliran CloudWatch Log, peran IAM, dan kebijakan IAM) akan dibuat untuk Anda. 

    Saat Anda membuat aplikasi menggunakan konsol, Anda menentukan versi Apache Flink yang digunakan aplikasi Anda dengan memilihnya dari pull-down pada halaman **Managed Service for Apache Flink** - Create application. 

    Untuk tutorial tentang cara menggunakan konsol untuk membuat aplikasi, lihat [Tutorial: Mulai menggunakan DataStream API di Managed Service untuk Apache Flink](getting-started.md) tutorialnya.
  + **Buat aplikasi Amazon MSF Anda menggunakan AWS CLI**: Anda dapat membuat dan mengkonfigurasi aplikasi Anda menggunakan CLI. AWS 

    Saat Anda membuat aplikasi menggunakan CLI, Anda juga harus membuat sumber daya dependen aplikasi Anda (seperti aliran CloudWatch Log, peran IAM, dan kebijakan IAM) secara manual.

    Ketika Anda membuat aplikasi Anda menggunakan CLI, Anda menentukan versi Apache Flink yang digunakan aplikasi Anda menggunakan parameter `RuntimeEnvironment` dari tindakan `CreateApplication`.
**catatan**  
Anda dapat mengubah `RuntimeEnvironment` aplikasi yang ada. Untuk mempelajari caranya, lihat [Gunakan upgrade versi di tempat untuk Apache Flink](how-in-place-version-upgrades.md).

## Gunakan kunci yang dikelola pelanggan
<a name="how-creating-apps-use-cmk"></a>

Di Amazon MSF, Customer Managed Keys (CMK) adalah fitur yang dapat digunakan untuk mengenkripsi data aplikasi Anda dengan kunci yang Anda buat, miliki, dan kelola pada AWS Key Management Service ().AWS KMS Untuk aplikasi Amazon MSF, ini berarti semua data yang tunduk pada [pos pemeriksaan](how-fault.md) Flink atau [snapshot](how-snapshots.md) dienkripsi dengan CMK yang Anda tentukan untuk aplikasi itu.

Untuk menggunakan CMK dengan aplikasi Anda, Anda harus terlebih dahulu [membuat aplikasi baru Anda](#how-creating-apps-creating), dan kemudian menerapkan CMK. Untuk informasi selengkapnya tentang menggunakan CMK, lihat[Manajemen kunci di Amazon Managed Service untuk Apache Flink](key-management-flink.md).

## Mulai Layanan Terkelola Anda untuk aplikasi Apache Flink
<a name="how-creating-apps-starting"></a>

Setelah Anda membangun kode aplikasi Anda, mengunggahnya ke S3, dan membuat Layanan Terkelola untuk aplikasi Apache Flink, Anda kemudian memulai aplikasi Anda. Memulai Layanan Terkelola untuk aplikasi Apache Flink biasanya memakan waktu beberapa menit.

Gunakan salah satu metode berikut untuk memulai aplikasi Anda:
+ **Mulai Layanan Terkelola untuk aplikasi Apache Flink menggunakan AWS konsol:** Anda dapat menjalankan aplikasi Anda dengan memilih **Jalankan** pada halaman aplikasi Anda di AWS konsol.
+ **Mulai Layanan Terkelola untuk aplikasi Apache Flink menggunakan AWS API:** Anda dapat menjalankan aplikasi Anda menggunakan tindakan. [StartApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_StartApplication.html) 

## Verifikasi Layanan Terkelola Anda untuk aplikasi Apache Flink
<a name="how-creating-apps-verifying"></a>

Anda dapat memverifikasi bahwa aplikasi Anda bekerja dengan cara berikut:
+ **Menggunakan CloudWatch Log:** Anda dapat menggunakan Wawasan CloudWatch CloudWatch Log dan Log untuk memverifikasi bahwa aplikasi Anda berjalan dengan benar. Untuk informasi tentang menggunakan CloudWatch Log dengan Layanan Terkelola untuk aplikasi Apache Flink, lihat. [Pencatatan dan pemantauan di Amazon Managed Service untuk Apache Flink](monitoring-overview.md)
+ **Menggunakan CloudWatch Metrik:** Anda dapat menggunakan CloudWatch Metrik untuk memantau aktivitas aplikasi, atau aktivitas dalam sumber daya yang digunakan aplikasi untuk input atau output (seperti aliran Kinesis, aliran Firehose, atau bucket Amazon S3.) Untuk informasi selengkapnya tentang CloudWatch metrik, lihat [Bekerja dengan Metrik](https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/working_with_metrics.html) di CloudWatch Panduan Pengguna Amazon.
+ **Pemantauan Lokasi Output:** Jika aplikasi Anda menulis output ke lokasi (seperti bucket atau basis data Amazon S3), Anda dapat memantau lokasi tersebut untuk data tertulis.