本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
程式設計 Flink 組態屬性
以下是您可以直接在應用程式程式碼中修改的 Flink 組態屬性。從 MSF 2.2 開始,如果您嘗試修改應用程式程式碼中此頁面未列出的屬性,則會擲回例外狀況。
注意
這些屬性與透過 AWS 支援案例修改的設定不同。如需 TaskManager 記憶體、狀態後端、RocksDB 調校和重新啟動策略等基礎設施層級設定,請參閱 可修改的 Flink 組態屬性。
管道組態
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
Python API
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
資料表 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