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.type:

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 dalla REST API di Flink con strumenti personalizzati.

Managed Service for Apache Flink consente ai clienti di accedere all'ultima API REST di Flink (o alla versione supportata in uso) in modalità di sola lettura utilizzando l'API. CreateApplicationPresignedUrl Questa API viene utilizzata dalla dashboard di Flink, ma può essere utilizzata anche da strumenti di monitoraggio personalizzati.

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:

Opzioni RockSDB

state.backend.rocksdb.compaction.style:

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

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.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:

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'endpoint e il client REST

rest.flamegraph.enabled:

rest.server.numThreads:

Opzioni di sicurezza SSL avanzate

security.ssl.internal.handshake-timeout:

Opzioni di pianificazione avanzate

slot.request.timeout:

Opzioni avanzate per l'interfaccia utente web di Flink

web.timeout: