本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
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 的更多信息,请参阅以下内容: