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

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