0

我们正在尝试在 AWS Kinesis 上运行查询,并使用自动缩放。

我们发现,如果用户在 AWS Kinesis 配置中指定了 Parallelism 选项,AWS Kinesis 会将指定的并行度应用于所有算子。

我们还尝试在不指定任何并行度的情况下运行查询(将ConfigurationType 设置为 DEFAULT)。在这种情况下,Kinesis 只会启动 1 个具有 1 个插槽的任务管理器,即使这还不足以运行我们的查询。

所以我们想知道 AWS Kinesis Auto Scaling 是否支持为不同的算子设置不同的并行度?

谢谢

4

0 回答 0