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 值增加到最大并行度，即应用程序的最大 KPU 的 ParalellismPerKPU 倍。应用程序的最大 KPU 默认为 32 个，可以请求增加限制以增加该数值。如果减少应用程序负载，则该服务可以将 CurrentParallelism 值降至 Parallelism 设置。

类型：整数

有效范围：最小值为 1。

必需：否

ParallelismPerKPU

描述 Apache Flink 托管服务应用程序在其使用的每个 Kinesis 处理单元（KPU）中可以执行的并行任务数。有关 KPU 的更多信息，请参阅适用于 Apache Flink 的 Amazon 托管服务定价。

类型：整数

有效范围：最小值为 1。

必需：否

另请参阅

有关在特定语言的 AWS SDK 中使用此 API 的更多信息，请参阅以下内容：

• AWS 适用于 C++ 的 SDK

• AWS 适用于 Java 的 SDK V2

• AWS 适用于 Ruby V3 的 SDK