Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

수정 가능한 Flink 구성 속성

다음은 지원 사례를 사용하여 수정할 수 있는 Flink 구성 설정입니다. 애플리케이션 접두사를 지정하여 한 번에 둘 이상의 속성을 수정할 수 있으며 여러 애플리케이션의 속성을 동시에 수정할 수 있습니다. 이 목록 외에 수정하려는 다른 Flink 구성 속성이 있는 경우 케이스에 맞는 정확한 속성을 지정하십시오.

재시작 전략

Flink 1.19 이상부터는 기본적으로 exponential-delay 재시작 전략을 사용합니다. 모든 이전 버전은 기본적으로 fixed-delay 재시작 전략을 사용합니다.

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:

체크포인트 및 상태 백엔드

state.backend:

state.backend.fs.memory-threshold:

state.backend.incremental:

체크포인트

execution.checkpointing.unaligned:

execution.checkpointing.interval-during-backlog:

RocksDB 네이티브 메트릭

RocksDB 네이티브 메트릭은 배송되지 않습니다. CloudWatch 일단 활성화되면 Flink 대시보드 또는 Flink에서 사용자 지정 도구를 사용하여 이러한 메트릭에 액세스할 수 있습니다. REST API

Apache Flink용 관리형 서비스를 통해 고객은 를 사용하여 읽기 전용 모드에서 최신 Flink RESTAPI(또는 사용 중인 지원 버전) 에 액세스할 수 있습니다. CreateApplicationPresignedUrlAPI 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.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:

플링크 웹 UI의 고급 옵션

web.timeout: