Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

可修改的 Flink 配置属性

以下是您可以使用支持案例修改的 Flink 配置设置。通过指定应用程序前缀，您可以一次修改多个属性，也可以同时修改多个应用程序的属性。如果您要修改此列表之外的其他 Flink 配置属性，请根据您的具体情况指定确切的属性。

容错能力

restart-strategy:

restart-strategy.fixed-delay.delay:

检查点和状态后端

state.backend:

state.backend.fs.memory-threshold:

state.backend.incremental:

检查点

execution.checkpointing.unaligned:

RocksDB 原生指标

RocksDB 原生指标不会提供给 CloudWatch。启用后，可以通过 Flink 控制面板或使用自定义工具通过 Flink REST API 访问这些指标。

Managed Service for Apache Flink 使客户能够使用 创建应用程序 PresigneDurl API 以只读模式访问最新的 Flink REST API（或您正在使用的支持的版本）。此 API 由 Flink 自己的控制面板使用，但也可以由自定义监控工具使用。

state.backend.rocksdb.compaction.style:

state.backend.rocksdb.memory.partitioned-index-filters:

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:

state.backend.rocksdb.thread.num:

高级状态后端选项

state.storage.fs.memory-threshold:

完整的 TaskManager 选项

task.cancellation.timeout:

taskmanager.jvm-exit-on-oom:

taskmanager.numberOfTaskSlots:

taskmanager.slot.timeout:

taskmanager.network.memory.fraction:

taskmanager.network.memory.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:

内存配置

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:

客户端

client.timeout:

高级集群选项

cluster.intercept-user-system-exit:

cluster.processes.halt-on-fatal-error:

文件系统配置

fs.s3.connection.maximum:

fs.s3a.connection.maximum:

fs.s3a.threads.max:

s3.upload.max.concurrent.uploads:

高级容错选项

heartbeat.timeout:

jobmanager.execution.failover-strategy:

内存配置

jobmanager.memory.heap.size:

指标

metrics.latency.interval:

REST 端点和客户端的高级选项

rest.flamegraph.enabled:

rest.server.numThreads:

高级SSL 安全选项

security.ssl.internal.handshake-timeout:

高级计划选项

slot.request.timeout:

Flink Web 用户界面的高级选项

web.timeout: