Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Pengaturan Apache Flink
Managed Service untuk Apache Flink adalah implementasi dari kerangka Apache Flink. Layanan Terkelola untuk Apache Flink menggunakan nilai default yang dijelaskan di bagian ini. Beberapa nilai ini dapat diatur oleh Layanan Terkelola untuk aplikasi Apache Flink dalam kode, dan lainnya tidak dapat diubah.
Gunakan tautan di bagian ini untuk mempelajari lebih lanjut tentang pengaturan Apache flink dan mana yang dapat dimodifikasi.
**Topics**
+ [Konfigurasi Apache Flink](#apache-flink-configuration)
+ [Backend negara](#reference-defaults-state-backend)
+ [Checkpointing](#reference-defaults-checkpoint)
+ [Menyimpan](#reference-defaults-savepoint)
+ [Ukuran tumpukan](#reference-defaults-heap)
+ [Buffer debloating](#reference-defaults-buffer-debloating)
+ [Properti konfigurasi Flink yang dapat dimodifikasi](reference-modifiable-settings.md)
+ [Properti konfigurasi Flink terprogram](programmatic-configuration.md)
+ [Lihat properti Flink yang dikonfigurasi](viewing-modifiable-settings.md)
## Konfigurasi Apache Flink
Managed Service for Apache Flink menyediakan konfigurasi Flink default yang terdiri dari nilai yang direkomendasikan Apache Flink untuk sebagian besar properti dan beberapa berdasarkan profil aplikasi umum. Untuk informasi selengkapnya tentang konfigurasi Flink, lihat [Konfigurasi](https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/). Konfigurasi default yang disediakan layanan berfungsi untuk sebagian besar aplikasi. Namun, untuk mengubah properti konfigurasi Flink untuk meningkatkan kinerja untuk aplikasi tertentu dengan paralelisme tinggi, memori tinggi dan penggunaan status, atau mengaktifkan fitur debugging baru di Apache Flink, Anda dapat mengubah properti tertentu dengan meminta kasus dukungan. Untuk informasi selengkapnya, lihat [Pusat Dukungan AWS](https://console.aws.amazon.com/support/home#/). Anda dapat memeriksa konfigurasi saat ini untuk aplikasi Anda menggunakan [Apache Flink Dashboard](https://docs.aws.amazon.com/managed-flink/latest/java/how-dashboard.html).
## Backend negara
Layanan Terkelola untuk Apache Flink menyimpan data sementara di backend status. Managed Service untuk Apache Flink menggunakan **Rocks DBState** Backend. Memanggil `setStateBackend` untuk mengatur backend yang berbeda tidak memiliki pengaruh.
Kami mengaktifkan fitur berikut pada backend status:
+ Snapshot backend status tambahan
+ Snapshot backend status asinkron
+ Pemulihan lokal titik pemeriksaan
Untuk informasi selengkapnya tentang backend status, lihat Backend [Status di Dokumentasi](https://nightlies.apache.org/flink/flink-docs-release-1.19/ops/state/state_backends.html) Apache Flink.
## Checkpointing
Layanan Terkelola untuk Apache Flink menggunakan konfigurasi pos pemeriksaan default dengan nilai-nilai berikut. Beberapa nilai ini dapat diubah menggunakan [CheckpointConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CheckpointConfiguration.html). Anda harus mengatur `CheckpointConfiguration.ConfigurationType` untuk Managed Service `CUSTOM` for Apache Flink untuk menggunakan nilai checkpointing yang dimodifikasi.
****
| Pengaturan | Bisa dimodifikasi? | Bagaimana | nilai default |
| --- | --- | --- | --- |
| CheckpointingEnabled | Dapat diubah | [Buat Aplikasi](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [Perbarui Aplikasi](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html) | True |
| CheckpointInterval | Dapat diubah | [Buat Aplikasi](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [Perbarui Aplikasi](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html) | 60000 |
| MinPauseBetweenCheckpoints | Dapat diubah | [Buat Aplikasi](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [Perbarui Aplikasi](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html) | 5000 |
| Pos pemeriksaan tidak selaras | Dapat diubah | [Kasus Support](https://console.aws.amazon.com/support/home#/) | False |
| Jumlah Titik Pemeriksaan Konkuren | Tidak Dapat Dimodifikasi | N/A | 1 |
| Mode Checkpointing | Tidak Dapat Dimodifikasi | N/A | Tepat Satu Kali |
| Kebijakan Penyimpanan Titik Pemeriksaan | Tidak Dapat Dimodifikasi | N/A | Pada Kegagalan |
| Waktu Habis Titik Pemeriksaan | Tidak Dapat Dimodifikasi | N/A | 60 menit |
| Titik Pemeriksaan Maks. yang Disimpan | Tidak Dapat Dimodifikasi | N/A | 1 |
| Lokasi Titik Pemeriksaan dan Titik Simpan | Tidak Dapat Dimodifikasi | N/A | Kami menyimpan data titik pemeriksaan dan titik simpan yang tahan lama ke bucket S3 milik layanan. |
## Menyimpan
Secara default, ketika memulihkan dari titik simpan, operasi lanjutkan akan mencoba memetakan semua status titik simpan kembali ke program yang Anda pulihkan. Jika Anda menghapus operator, secara default, memulihkan dari titik simpan yang memiliki data yang sesuai dengan operator yang hilang akan gagal. Anda dapat mengizinkan operasi berhasil dengan mengatur *AllowNonRestoredState*parameter aplikasi [FlinkRunConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_FlinkRunConfiguration.html)ke`true`. Ini akan memungkinkan operasi lanjutkan melewati status yang tidak dapat dipetakan ke program baru.
Untuk informasi selengkapnya, lihat [Mengizinkan Status yang Tidak Dipulihkan](https://nightlies.apache.org/flink/flink-docs-release-1.15/ops/state/savepoints.html#allowing-non-restored-state) di [Dokumentasi Apache Flink](https://nightlies.apache.org/flink/flink-docs-release-1.15/).
## Ukuran tumpukan
Managed Service untuk Apache Flink mengalokasikan masing-masing KPU 3 GiB tumpukan JVM, dan cadangan 1 GiB untuk alokasi kode asli. Untuk informasi tentang meningkatkan kapasitas aplikasi Anda, lihat [Menerapkan penskalaan aplikasi di Managed Service untuk Apache Flink](how-scaling.md).
Untuk informasi selengkapnya tentang ukuran tumpukan JVM, lihat [Konfigurasi](https://nightlies.apache.org/flink/flink-docs-release-1.15/ops/config.html) di [Dokumentasi Apache Flink](https://nightlies.apache.org/flink/flink-docs-release-1.15/).
## Buffer debloating
Buffer debloating dapat membantu aplikasi dengan tekanan balik tinggi. Jika aplikasi Anda mengalami pos pemeriksaan/savepoint yang gagal, mengaktifkan fitur ini bisa berguna. Untuk melakukan ini, minta [kasus dukungan](https://console.aws.amazon.com/support/home#/).
Untuk informasi selengkapnya, lihat [Mekanisme Debloating Buffer di dokumentasi](https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/memory/network_mem_tuning/#the-buffer-debloating-mechanism) [Apache](https://nightlies.apache.org/flink/flink-docs-release-1.15/) Flink.
# Properti konfigurasi Flink yang dapat dimodifikasi
Berikut ini adalah pengaturan konfigurasi Flink yang dapat Anda modifikasi menggunakan [kasus dukungan](https://console.aws.amazon.com/support/home#/). Anda dapat memodifikasi lebih dari satu properti pada satu waktu, dan untuk beberapa aplikasi pada saat yang sama dengan menentukan awalan aplikasi. Jika ada properti konfigurasi Flink lain di luar daftar ini yang ingin Anda ubah, tentukan properti yang tepat dalam kasus Anda.
## Mulai ulang strategi
Dari Flink 1.19 dan yang lebih baru, kami menggunakan strategi `exponential-delay` restart secara default. Semua versi sebelumnya menggunakan strategi `fixed-delay` restart secara default.
`restart-strategy:`
`restart-strategy.fixed-delay.delay:`
`restart-strategy.exponential-delay.backoff-muliplier:`
`restart-strategy.exponential-delay.initial-backoff:`
`restart-strategy.exponential-delay.jitter-factor:`
`restart-strategy.exponential-delay.reset-backoff-threshold:`
## Pos pemeriksaan dan backend status
`state.backend.type:`
`state.backend.fs.memory-threshold:`
`state.backend.incremental:`
## Checkpointing
`execution.checkpointing.unaligned:`
`execution.checkpointing.interval-during-backlog:`
## Metrik asli RocksDB
Metrik Asli RocksDB tidak dikirim ke. CloudWatch Setelah diaktifkan, metrik ini dapat diakses baik dari dasbor Flink atau Flink REST API dengan perkakas khusus.
Managed Service for Apache Flink memungkinkan pelanggan mengakses Flink [REST API](https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/rest_api/) terbaru (atau versi yang didukung yang Anda gunakan) dalam mode read-only menggunakan API. [CreateApplicationPresignedUrl](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplicationPresignedUrl.html) API ini digunakan oleh dasbor Flink sendiri, tetapi juga dapat digunakan oleh alat pemantauan khusus.
`state.backend.rocksdb.metrics.actual-delayed-write-rate:`
`state.backend.rocksdb.metrics.background-errors:`
`state.backend.rocksdb.metrics.block-cache-capacity:`
`state.backend.rocksdb.metrics.block-cache-pinned-usage:`
`state.backend.rocksdb.metrics.block-cache-usage:`
`state.backend.rocksdb.metrics.column-family-as-variable:`
`state.backend.rocksdb.metrics.compaction-pending:`
`state.backend.rocksdb.metrics.cur-size-active-mem-table:`
`state.backend.rocksdb.metrics.cur-size-all-mem-tables:`
`state.backend.rocksdb.metrics.estimate-live-data-size:`
`state.backend.rocksdb.metrics.estimate-num-keys:`
`state.backend.rocksdb.metrics.estimate-pending-compaction-bytes:`
`state.backend.rocksdb.metrics.estimate-table-readers-mem:`
`state.backend.rocksdb.metrics.is-write-stopped:`
`state.backend.rocksdb.metrics.mem-table-flush-pending:`
`state.backend.rocksdb.metrics.num-deletes-active-mem-table:`
`state.backend.rocksdb.metrics.num-deletes-imm-mem-tables:`
`state.backend.rocksdb.metrics.num-entries-active-mem-table:`
`state.backend.rocksdb.metrics.num-entries-imm-mem-tables:`
`state.backend.rocksdb.metrics.num-immutable-mem-table:`
`state.backend.rocksdb.metrics.num-live-versions:`
`state.backend.rocksdb.metrics.num-running-compactions:`
`state.backend.rocksdb.metrics.num-running-flushes:`
`state.backend.rocksdb.metrics.num-snapshots:`
`state.backend.rocksdb.metrics.size-all-mem-tables:`
## Opsi RocksDB
`state.backend.rocksdb.compaction.style:`
`state.backend.rocksdb.memory.partitioned-index-filters:`
`state.backend.rocksdb.thread.num:`
## Opsi backend status lanjutan
`state.storage.fs.memory-threshold:`
## TaskManager Opsi lengkap
`task.cancellation.timeout:`
`taskmanager.jvm-exit-on-oom:`
`taskmanager.numberOfTaskSlots:`
`taskmanager.slot.timeout:`
`taskmanager.memory.network.fraction:`
`taskmanager.memory.network.max:`
`taskmanager.network.request-backoff.initial:`
`taskmanager.network.request-backoff.max:`
`taskmanager.network.memory.buffer-debloat.enabled:`
`taskmanager.network.memory.buffer-debloat.period:`
`taskmanager.network.memory.buffer-debloat.samples:`
`taskmanager.network.memory.buffer-debloat.threshold-percentages:`
## Konfigurasi memori
`taskmanager.memory.jvm-metaspace.size:`
`taskmanager.memory.jvm-overhead.fraction:`
`taskmanager.memory.jvm-overhead.max:`
`taskmanager.memory.managed.consumer-weights:`
`taskmanager.memory.managed.fraction:`
`taskmanager.memory.network.fraction:`
`taskmanager.memory.network.max:`
`taskmanager.memory.segment-size:`
`taskmanager.memory.task.off-heap.size:`
## RPC/Akka
`akka.ask.timeout:`
`akka.client.timeout:`
`akka.framesize:`
`akka.lookup.timeout:`
`akka.tcp.timeout:`
## Klien
`client.timeout:`
## Opsi cluster lanjutan
`cluster.intercept-user-system-exit:`
`cluster.processes.halt-on-fatal-error:`
## Konfigurasi sistem file
`fs.s3.connection.maximum:`
`fs.s3a.connection.maximum:`
`fs.s3a.threads.max:`
`s3.upload.max.concurrent.uploads:`
## Opsi toleransi kesalahan tingkat lanjut
`heartbeat.timeout:`
`jobmanager.execution.failover-strategy:`
## Konfigurasi memori
`jobmanager.memory.heap.size:`
## Metrik-metrik
`metrics.latency.interval:`
## Opsi lanjutan untuk titik akhir dan klien REST
`rest.flamegraph.enabled:`
`rest.server.numThreads:`
## Opsi keamanan SSL tingkat lanjut
`security.ssl.internal.handshake-timeout:`
## Opsi penjadwalan lanjutan
`slot.request.timeout:`
## Opsi lanjutan untuk UI web Flink
`web.timeout:`
# Properti konfigurasi Flink terprogram
Berikut ini adalah properti konfigurasi Flink yang dapat Anda modifikasi langsung dalam kode aplikasi Anda. Dimulai dengan MSF 2.2, pengecualian akan dilemparkan jika Anda mencoba memodifikasi properti yang tidak tercantum di halaman ini dalam kode aplikasi Anda.
**catatan**
Properti ini berbeda dari pengaturan yang dimodifikasi melalui kasus AWS Support. Untuk pengaturan tingkat infrastruktur seperti TaskManager memori, backend status, penyetelan RocksDB, dan strategi restart, lihat. [Properti konfigurasi Flink yang dapat dimodifikasi](reference-modifiable-settings.md)
## Konfigurasi alur
`execution.runtime-mode`
`pipeline.auto-generate-uids`
`pipeline.auto-watermark-interval`
`pipeline.cached-files`
`pipeline.classpaths`
`pipeline.closure-cleaner-level`
`pipeline.force-avro`
`pipeline.force-kryo`
`pipeline.generic-types`
`pipeline.global-job-parameters`
`pipeline.jars`
`pipeline.jobvertex-parallelism-overrides`
`pipeline.max-parallelism`
`pipeline.name`
`pipeline.object-reuse`
`pipeline.operator-chaining.chain-operators-with-different-max-parallelism`
`pipeline.operator-chaining.enabled`
`pipeline.serialization-config`
`pipeline.vertex-description-mode`
`pipeline.vertex-name-include-index-prefix`
`pipeline.watermark-alignment.allow-unaligned-source-splits`
## API Python
`python.execution-mode`
`python.operator-chaining.enabled`
`python.job-options`
`python.internal.archives-key-map`
`python.internal.files-key-map`
`python.internal.requirements-file-key`
## Tabel API/SQL
`table.exec.async-lookup.buffer-capacity`
`table.exec.async-lookup.key-ordered-enabled`
`table.exec.async-lookup.output-mode`
`table.exec.async-lookup.timeout`
`table.exec.async-ml-predict.max-concurrent-operations`
`table.exec.async-ml-predict.output-mode`
`table.exec.async-ml-predict.timeout`
`table.exec.async-scalar.max-concurrent-operations`
`table.exec.async-scalar.max-attempts`
`table.exec.async-scalar.retry-delay`
`table.exec.async-scalar.retry-strategy`
`table.exec.async-scalar.timeout`
`table.exec.async-state.enabled`
`table.exec.async-table.max-concurrent-operations`
`table.exec.async-table.max-retries`
`table.exec.async-table.retry-delay`
`table.exec.async-table.retry-strategy`
`table.exec.async-table.timeout`
`table.exec.async-vector-search.max-concurrent-operations`
`table.exec.async-vector-search.output-mode`
`table.exec.async-vector-search.timeout`
`table.exec.deduplicate.insert-update-after-sensitive-enabled`
`table.exec.deduplicate.mini-batch.compact-changes-enabled`
`table.exec.delta-join.cache-enabled`
`table.exec.disabled-operators`
`table.exec.iceberg.use-v2-sink`
`table.exec.interval-join.min-cleanup-interval`
`table.exec.legacy-cast-behaviour`
`table.exec.local-hash-agg.adaptive.distinct-value-rate-threshold`
`table.exec.local-hash-agg.adaptive.enabled`
`table.exec.local-hash-agg.adaptive.sampling-threshold`
`table.exec.mini-batch.allow-latency`
`table.exec.mini-batch.enabled`
`table.exec.mini-batch.size`
`table.exec.operator-fusion-codegen.enabled`
`table.exec.simplify-operator-name-enabled`
`table.exec.sink.keyed-shuffle`
`table.exec.sink.nested-constraint-enforcer`
`table.exec.sink.not-null-enforcer`
`table.exec.sink.rowtime-inserter`
`table.exec.sink.type-length-enforcer`
`table.exec.sink.upsert-materialize`
`table.exec.sink.upsert-materialize-strategy.adaptive.threshold.high`
`table.exec.sink.upsert-materialize-strategy.adaptive.threshold.low`
`table.exec.sink.upsert-materialize-strategy.type`
`table.exec.sort.async-merge-enabled`
`table.exec.sort.default-limit`
`table.exec.sort.max-num-file-handles`
`table.exec.source.cdc-events-duplicate`
`table.exec.source.idle-timeout`
`table.exec.spill-compression.block-size`
`table.exec.spill-compression.enabled`
`table.exec.state.ttl`
`table.exec.uid.format`
`table.exec.uid.generation`
`table.exec.unbounded-over.version`
`table.exec.window-agg.buffer-size-limit`
`table.optimizer.agg-phase-strategy`
`table.optimizer.adaptive-broadcast-join.strategy`
`table.optimizer.bushy-join-reorder-threshold`
`table.optimizer.delta-join.strategy`
`table.optimizer.distinct-agg.split.bucket-num`
`table.optimizer.distinct-agg.split.enabled`
`table.optimizer.dynamic-filtering.enabled`
`table.optimizer.incremental-agg-enabled`
`table.optimizer.join-reorder-enabled`
`table.optimizer.multi-join.enabled`
`table.optimizer.multiple-input-enabled`
`table.optimizer.non-deterministic-update.strategy`
`table.optimizer.reuse-optimize-block-with-digest-enabled`
`table.optimizer.reuse-sink-enabled`
`table.optimizer.reuse-source-enabled`
`table.optimizer.reuse-sub-plan-enabled`
`table.optimizer.runtime-filter.enabled`
`table.optimizer.skewed-join-optimization.skewed-factor`
`table.optimizer.skewed-join-optimization.skewed-threshold`
`table.optimizer.skewed-join-optimization.strategy`
`table.optimizer.source.report-statistics-enabled`
`table.optimizer.union-all-as-breakpoint-enabled`
`table.builtin-catalog-name`
`table.builtin-database-name`
`table.catalog-modification.listeners`
`table.column-expansion-strategy`
`table.display.max-column-width`
`table.dml-sync`
`table.dynamic-table-options.enabled`
`table.generated-code.max-length`
`table.legacy-nested-row-nullability`
`table.local-time-zone`
`table.plan.compile.catalog-objects`
`table.plan.force-recompile`
`table.plan.restore.catalog-objects`
`table.rtas-ctas.atomicity-enabled`
`table.sql-dialect`
# Lihat properti Flink yang dikonfigurasi
Anda dapat melihat properti Apache Flink yang telah Anda konfigurasikan sendiri atau diminta untuk dimodifikasi melalui [kasus dukungan](https://support.console.aws.amazon.com/support/home#/) melalui Dasbor Apache Flink dan mengikuti langkah-langkah berikut:
1. Pergi ke Dasbor Flink
1. Pilih **Job Manager** di panel navigasi sisi kiri.
1. Pilih **Konfigurasi** untuk melihat daftar properti Flink.