Amazon Managed Service para Apache Flink Amazon se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Propiedades de configuración de Flink modificables

A continuación, se muestran los ajustes de configuración de Flink que puede modificar mediante un caso de soporte. Puede modificar más de una propiedad a la vez y para varias aplicaciones al mismo tiempo especificando el prefijo de la aplicación. Si hay otras propiedades de configuración de Flink fuera de esta lista que desee modificar, especifique la propiedad exacta en su caso.

Reinicie la estrategia

A partir de la versión 1.19 de Flink y versiones posteriores, utilizamos la estrategia de exponential-delay reinicio de forma predeterminada. Todas las versiones anteriores utilizan la estrategia de fixed-delay reinicio de forma predeterminada.

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:

Puntos de control y backends estatales

state.backend:

state.backend.fs.memory-threshold:

state.backend.incremental:

Creación de puntos de control

execution.checkpointing.unaligned:

execution.checkpointing.interval-during-backlog:

Métricas nativas de RockSDB

Las métricas nativas de RockSDB no se envían a. CloudWatch Una vez activadas, se puede acceder a estas métricas desde el panel de control de Flink o desde Flink REST API con herramientas personalizadas.

El servicio gestionado para Apache Flink permite a los clientes acceder a la versión más reciente de Flink RESTAPI(o a la versión compatible que estén utilizando) en modo de solo lectura mediante el. CreateApplicationPresignedUrlAPI Esto API lo usa el propio panel de control de Flink, pero también lo pueden usar herramientas de monitoreo personalizadas.

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:

Opciones avanzadas de backend de estado

state.storage.fs.memory-threshold:

Opciones completas 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:

Configuración de memoria

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:

Cliente

client.timeout:

Opciones de clúster avanzadas

cluster.intercept-user-system-exit:

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

Configuraciones del sistema de archivos

fs.s3.connection.maximum:

fs.s3a.connection.maximum:

fs.s3a.threads.max:

s3.upload.max.concurrent.uploads:

Opciones avanzadas de tolerancia a fallos

heartbeat.timeout:

jobmanager.execution.failover-strategy:

Configuración de memoria

jobmanager.memory.heap.size:

Métricas

metrics.latency.interval:

Opciones avanzadas para el REST terminal y el cliente

rest.flamegraph.enabled:

rest.server.numThreads:

Opciones SSL de seguridad avanzadas

security.ssl.internal.handshake-timeout:

Opciones de programación avanzadas

slot.request.timeout:

Opciones avanzadas para la interfaz de usuario web de Flink

web.timeout: