Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Proprietà di configurazione modificabili di Flink

Di seguito sono riportate le impostazioni di configurazione di Flink che è possibile modificare utilizzando un case di supporto. È possibile modificare più di una proprietà alla volta e per più applicazioni contemporaneamente specificando il prefisso dell'applicazione. Se ci sono altre proprietà di configurazione Flink al di fuori di questo elenco che desideri modificare, specifica la proprietà esatta nel tuo caso.

strategia di riavvio

A partire da Flink 1.19 e versioni successive, utilizziamo la strategia di exponential-delay riavvio per impostazione predefinita. Tutte le versioni precedenti utilizzano la strategia di fixed-delay riavvio per impostazione predefinita.

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:

Checkpoint e backend di stato

state.backend:

state.backend.fs.memory-threshold:

state.backend.incremental:

Checkpoint

execution.checkpointing.unaligned:

execution.checkpointing.interval-during-backlog:

Metriche native di RocksDB

Le metriche native di RockSDB non vengono spedite a. CloudWatch Una volta abilitate, è possibile accedere a queste metriche dalla dashboard di Flink o da Flink con strumenti personalizzati. REST API

Il servizio gestito per Apache Flink consente ai clienti di accedere all'ultima versione di Flink RESTAPI(o alla versione supportata in uso) in modalità di sola lettura utilizzando il. CreateApplicationPresignedUrlAPI APIViene utilizzato dalla dashboard di Flink, ma può essere utilizzato anche da strumenti di monitoraggio personalizzati.

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:

Opzioni avanzate di backend di stato

state.storage.fs.memory-threshold:

Opzioni complete 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:

Configurazione della 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:

Client

client.timeout:

Opzioni di cluster avanzate

cluster.intercept-user-system-exit:

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

Configurazioni del file system

fs.s3.connection.maximum:

fs.s3a.connection.maximum:

fs.s3a.threads.max:

s3.upload.max.concurrent.uploads:

Opzioni avanzate di tolleranza ai guasti

heartbeat.timeout:

jobmanager.execution.failover-strategy:

Configurazione della memoria

jobmanager.memory.heap.size:

Metriche

metrics.latency.interval:

Opzioni avanzate per l'RESTendpoint e il client

rest.flamegraph.enabled:

rest.server.numThreads:

Opzioni di SSL sicurezza avanzate

security.ssl.internal.handshake-timeout:

Opzioni di pianificazione avanzate

slot.request.timeout:

Opzioni avanzate per l'interfaccia utente web di Flink

web.timeout: