View a markdown version of this page

ParallelismConfiguration - Amazon Managed Servics for Apache Flink(前身为 Amazon Kinesis Data Analytics for Apache Flink)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

ParallelismConfiguration

描述针对 Apache Flink 托管服务应用程序如何同时执行多个任务的参数。有关并行性的更多信息,请参阅《Apache Flink 文档》中的并行执行。

内容

ConfigurationType

描述应用程序是否使用 Apache Flink 托管服务的默认并行度。您必须将此属性设置为 CUSTOM,以便更改您的应用程序的 AutoScalingEnabled、Parallelism 或 ParallelismPerKPU 属性。

类型:字符串

有效值:DEFAULT | CUSTOM

是否必需:是

AutoScalingEnabled

描述 Apache Flink 托管服务是否可以增加应用程序的并行度以响应提升的吞吐量。

类型:布尔值

必需:否

Parallelism

描述 Apache Flink 托管服务应用程序可以执行的初始并行任务数。如果 AutoScalingEnabled 设置为 True,则 Apache Flink 托管服务会根据应用程序负载增加 CurrentParallelism 值。该服务可以将该CurrentParallelism值增加到最大并行度,即应用程序的最大并行 KPUs 度的ParalellismPerKPU倍数。默认情况下 KPUs,应用程序的最大值为 64,可以通过请求提高限制来增加。如果减少应用程序负载,则该服务可以将 CurrentParallelism 值降至 Parallelism 设置。

类型:整数

有效范围:最小值为 1。

必需:否

ParallelismPerKPU

描述 Apache Flink 托管服务应用程序在其使用的每个 Kinesis 处理单元(KPU)中可以执行的并行任务数。有关更多信息 KPUs,请参阅适用于 A pache 的亚马逊托管服务 Flink 定价。

类型:整数

有效范围:最小值为 1。

必需:否

另请参阅

有关以特定语言之一使用此 API 的更多信息 AWS SDKs,请参阅以下内容: