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à. # Impostazioni Apache Flink Il servizio gestito per Apache Flink è un'implementazione del framework Apache Flink. Il servizio gestito per Apache Flink utilizza i valori predefiniti descritti in questa sezione. Alcuni di questi valori possono essere impostati dal servizio gestito per le applicazioni Apache Flink nel codice, mentre altri non possono essere modificati. Usa i link in questa sezione per saperne di più sulle impostazioni di Apache flink e su quali sono modificabili. **Topics** + [Configurazione di Apache Flink](#apache-flink-configuration) + [Backend statale](#reference-defaults-state-backend) + [Checkpoint](#reference-defaults-checkpoint) + [Savepoint](#reference-defaults-savepoint) + [Dimensioni del mucchio](#reference-defaults-heap) + [Debloating del buffer](#reference-defaults-buffer-debloating) + [Proprietà di configurazione modificabili di Flink](reference-modifiable-settings.md) + [Proprietà di configurazione programmatiche di Flink](programmatic-configuration.md) + [Visualizza le proprietà Flink configurate](viewing-modifiable-settings.md) ## Configurazione di Apache Flink Il servizio gestito per Apache Flink fornisce una configurazione Flink predefinita composta da valori consigliati da Apache Flink per la maggior parte delle proprietà e alcune basati su profili comuni per le applicazioni. Per ulteriori informazioni sulla configurazione di Flink, consulta [Configurazione](https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/). La configurazione predefinita fornita dal servizio funziona per la maggior parte delle applicazioni. Tuttavia, per modificare le proprietà di configurazione di Flink per migliorare le prestazioni di determinate applicazioni con elevato parallelismo, elevato utilizzo di memoria e stato o abilitare nuove funzionalità di debug in Apache Flink, puoi modificare determinate proprietà richiedendo un caso di supporto. Per ulteriori informazioni, consulta [Centro di supporto di AWS](https://console.aws.amazon.com/support/home#/). È possibile controllare la configurazione corrente dell'applicazione utilizzando la [dashboard di Apache Flink](https://docs.aws.amazon.com/managed-flink/latest/java/how-dashboard.html). ## Backend statale Il servizio gestito per Apache Flink archivia i dati transitori in un backend di stato. **Il servizio gestito per Apache Flink utilizza il backend Rocks. DBState** Chiamare `setStateBackend` per impostare un backend diverso non ha alcun effetto. Abilitiamo le seguenti funzionalità sul backend di stato: + Snapshot incrementali del backend di stato + Snapshot del backend di stato asincroni + Ripristino locale dei checkpoint Per ulteriori informazioni sui backend di stato, consulta [State Backends](https://nightlies.apache.org/flink/flink-docs-release-1.19/ops/state/state_backends.html) nella documentazione di Apache Flink. ## Checkpoint Il servizio gestito per Apache Flink utilizza una configurazione di checkpoint predefinita con i seguenti valori. Alcuni di questi valori possono essere modificati utilizzando. [CheckpointConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CheckpointConfiguration.html) È necessario `CheckpointConfiguration.ConfigurationType` impostare su Managed Service `CUSTOM` for Apache Flink per utilizzare i valori di checkpoint modificati. **** | Impostazione | Può essere modificato? | In che modo | Valore predefinito | | --- | --- | --- | --- | | CheckpointingEnabled | Modificabile | [Crea applicazione](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [Aggiorna applicazione](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html) | True | | CheckpointInterval | Modificabile | [Crea applicazione](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [Aggiorna applicazione](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html) | 60000 | | MinPauseBetweenCheckpoints | Modificabile | [Crea applicazione](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) [Aggiorna applicazione](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) [CloudFormation](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/AWS_KinesisAnalyticsV2.html) | 5000 | | Checkpoint non allineati | Modificabile | [Caso di supporto](https://console.aws.amazon.com/support/home#/) | False | | Numero di checkpoint simultanei | Non modificabile | N/D | 1 | | Modalità di checkpoint | Non modificabile | N/D | Esattamente una volta | | Policy di conservazione dei checkpoint | Non modificabile | N/D | In caso di errore | | Timeout checkpoint | Non modificabile | N/D | 60 minuti | | Max. di checkpoint mantenuti | Non modificabile | N/D | 1 | | Ubicazione di checkpoint e savepoint | Non modificabile | N/D | Archiviamo dati durevoli su checkpoint e savepoint in un bucket S3 di proprietà del servizio. | ## Savepoint Per impostazione predefinita, quando si esegue il ripristino da un savepoint, l'operazione di ripristino proverà a mappare tutto lo stato del savepoint nel programma con cui si sta eseguendo il ripristino. Se hai eliminato un operatore, per impostazione predefinita, il ripristino da un savepoint con dati corrispondenti all'operatore mancante avrà esito negativo. È possibile consentire il successo dell'operazione impostando il *AllowNonRestoredState*parametro dell'applicazione [FlinkRunConfiguration](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_FlinkRunConfiguration.html)su`true`. Ciò consentirà all'operazione di ripristino di ignorare uno stato che non può essere mappato nel nuovo programma. Per ulteriori informazioni, consulta la sezione [Consentire lo stato non ripristinato](https://nightlies.apache.org/flink/flink-docs-release-1.15/ops/state/savepoints.html#allowing-non-restored-state) nella [documentazione di Apache Flink](https://nightlies.apache.org/flink/flink-docs-release-1.15/). ## Dimensioni del mucchio Il servizio gestito per Apache Flink alloca 3 GB di heap JVM per ogni KPU e riserva 1 GB per le allocazioni di codice nativo. Per informazioni sull'aumento della capacità delle applicazioni, consulta [Implementazione della scalabilità delle applicazioni in Managed Service for Apache Flink](how-scaling.md). Per ulteriori informazioni sulle dimensioni heap di JVM, consultare [Configurazione](https://nightlies.apache.org/flink/flink-docs-release-1.15/ops/config.html) nella [documentazione di Apache Flink](https://nightlies.apache.org/flink/flink-docs-release-1.15/). ## Debloating del buffer Il debloating del buffer può aiutare le applicazioni che hanno una congestione elevata. Se l'applicazione presenta checkpoint/savepoint non riusciti, potrebbe essere utile abilitare questa funzionalità. A tal scopo, richiedi un [caso di supporto](https://console.aws.amazon.com/support/home#/). Per ulteriori informazioni, consulta [Il meccanismo di debloating del buffer](https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/memory/network_mem_tuning/#the-buffer-debloating-mechanism) nella documentazione di [Apache](https://nightlies.apache.org/flink/flink-docs-release-1.15/) Flink. # Proprietà di configurazione modificabili di Flink Di seguito sono riportate le impostazioni di configurazione di Flink che è possibile modificare utilizzando un case di [supporto](https://console.aws.amazon.com/support/home#/). È 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](https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/rest_api/) di Flink (o alla versione supportata in uso) in modalità di sola lettura utilizzando l'API. [CreateApplicationPresignedUrl](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplicationPresignedUrl.html) 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:` # Proprietà di configurazione programmatiche di Flink Di seguito sono riportate le proprietà di configurazione di Flink che è possibile modificare direttamente nel codice dell'applicazione. A partire da MSF 2.2, verrà generata un'eccezione se si tenta di modificare una proprietà non elencata in questa pagina nel codice dell'applicazione. **Nota** Queste proprietà sono diverse dalle impostazioni modificate tramite AWS Support case. Per le impostazioni a livello di infrastruttura come TaskManager memoria, backend di stato, ottimizzazione di RockSDB e strategie di riavvio, consulta. [Proprietà di configurazione modificabili di Flink](reference-modifiable-settings.md) ## Configurazione della pipeline `execution.runtime-mode` `pipeline.auto-generate-uids` `pipeline.auto-watermark-interval` `pipeline.cached-files` `pipeline.classpaths` `pipeline.closure-cleaner-level` `pipeline.force-avro` `pipeline.force-kryo` `pipeline.generic-types` `pipeline.global-job-parameters` `pipeline.jars` `pipeline.jobvertex-parallelism-overrides` `pipeline.max-parallelism` `pipeline.name` `pipeline.object-reuse` `pipeline.operator-chaining.chain-operators-with-different-max-parallelism` `pipeline.operator-chaining.enabled` `pipeline.serialization-config` `pipeline.vertex-description-mode` `pipeline.vertex-name-include-index-prefix` `pipeline.watermark-alignment.allow-unaligned-source-splits` ## API Python `python.execution-mode` `python.operator-chaining.enabled` `python.job-options` `python.internal.archives-key-map` `python.internal.files-key-map` `python.internal.requirements-file-key` ## Tabella API/ SQL `table.exec.async-lookup.buffer-capacity` `table.exec.async-lookup.key-ordered-enabled` `table.exec.async-lookup.output-mode` `table.exec.async-lookup.timeout` `table.exec.async-ml-predict.max-concurrent-operations` `table.exec.async-ml-predict.output-mode` `table.exec.async-ml-predict.timeout` `table.exec.async-scalar.max-concurrent-operations` `table.exec.async-scalar.max-attempts` `table.exec.async-scalar.retry-delay` `table.exec.async-scalar.retry-strategy` `table.exec.async-scalar.timeout` `table.exec.async-state.enabled` `table.exec.async-table.max-concurrent-operations` `table.exec.async-table.max-retries` `table.exec.async-table.retry-delay` `table.exec.async-table.retry-strategy` `table.exec.async-table.timeout` `table.exec.async-vector-search.max-concurrent-operations` `table.exec.async-vector-search.output-mode` `table.exec.async-vector-search.timeout` `table.exec.deduplicate.insert-update-after-sensitive-enabled` `table.exec.deduplicate.mini-batch.compact-changes-enabled` `table.exec.delta-join.cache-enabled` `table.exec.disabled-operators` `table.exec.iceberg.use-v2-sink` `table.exec.interval-join.min-cleanup-interval` `table.exec.legacy-cast-behaviour` `table.exec.local-hash-agg.adaptive.distinct-value-rate-threshold` `table.exec.local-hash-agg.adaptive.enabled` `table.exec.local-hash-agg.adaptive.sampling-threshold` `table.exec.mini-batch.allow-latency` `table.exec.mini-batch.enabled` `table.exec.mini-batch.size` `table.exec.operator-fusion-codegen.enabled` `table.exec.simplify-operator-name-enabled` `table.exec.sink.keyed-shuffle` `table.exec.sink.nested-constraint-enforcer` `table.exec.sink.not-null-enforcer` `table.exec.sink.rowtime-inserter` `table.exec.sink.type-length-enforcer` `table.exec.sink.upsert-materialize` `table.exec.sink.upsert-materialize-strategy.adaptive.threshold.high` `table.exec.sink.upsert-materialize-strategy.adaptive.threshold.low` `table.exec.sink.upsert-materialize-strategy.type` `table.exec.sort.async-merge-enabled` `table.exec.sort.default-limit` `table.exec.sort.max-num-file-handles` `table.exec.source.cdc-events-duplicate` `table.exec.source.idle-timeout` `table.exec.spill-compression.block-size` `table.exec.spill-compression.enabled` `table.exec.state.ttl` `table.exec.uid.format` `table.exec.uid.generation` `table.exec.unbounded-over.version` `table.exec.window-agg.buffer-size-limit` `table.optimizer.agg-phase-strategy` `table.optimizer.adaptive-broadcast-join.strategy` `table.optimizer.bushy-join-reorder-threshold` `table.optimizer.delta-join.strategy` `table.optimizer.distinct-agg.split.bucket-num` `table.optimizer.distinct-agg.split.enabled` `table.optimizer.dynamic-filtering.enabled` `table.optimizer.incremental-agg-enabled` `table.optimizer.join-reorder-enabled` `table.optimizer.multi-join.enabled` `table.optimizer.multiple-input-enabled` `table.optimizer.non-deterministic-update.strategy` `table.optimizer.reuse-optimize-block-with-digest-enabled` `table.optimizer.reuse-sink-enabled` `table.optimizer.reuse-source-enabled` `table.optimizer.reuse-sub-plan-enabled` `table.optimizer.runtime-filter.enabled` `table.optimizer.skewed-join-optimization.skewed-factor` `table.optimizer.skewed-join-optimization.skewed-threshold` `table.optimizer.skewed-join-optimization.strategy` `table.optimizer.source.report-statistics-enabled` `table.optimizer.union-all-as-breakpoint-enabled` `table.builtin-catalog-name` `table.builtin-database-name` `table.catalog-modification.listeners` `table.column-expansion-strategy` `table.display.max-column-width` `table.dml-sync` `table.dynamic-table-options.enabled` `table.generated-code.max-length` `table.legacy-nested-row-nullability` `table.local-time-zone` `table.plan.compile.catalog-objects` `table.plan.force-recompile` `table.plan.restore.catalog-objects` `table.rtas-ctas.atomicity-enabled` `table.sql-dialect` # Visualizza le proprietà Flink configurate Puoi visualizzare le proprietà di Apache Flink che hai configurato personalmente o che hai richiesto di modificare attraverso un [caso di supporto](https://support.console.aws.amazon.com/support/home#/) tramite la dashboard di Apache Flink e seguendo questi passaggi: 1. Vai alla dashboard di Flink 1. Scegli **Job Manager** nel riquadro di navigazione a sinistra. 1. Scegli **Configurazione** per visualizzare l'elenco delle proprietà di Flink.