Java SDK 2.11.0 上的数据流作业无法扩展

Question

我有一个流式作业，它从 pubsub 读取并写入 pubsub，在中间进行一些基本处理。
在使用 SDK 2.5.0 并“直接”执行时，它按预期工作，并根据需要从 1 个工作人员扩展到应有的工作人员数量。 尝试升级到最新版本 2.11.0，并尝试使用模板 - 它工作正常，但无法扩展。
附件是两个作业的管道选项。
有什么建议吗？我缺少的这两个版本之间可能发生了什么变化？
谢谢，
书树

澄清：
即使我设置了 20 个工人 - 我只得到 1 个。

Answer 1

numWorkers 设置为 20。因此，当作业开始时，将根据该值分配 20 个工人。

maxNumWorkers 也设置为 20。因此，分配的工作人员不会超过 20 个。

如果需要将作业扩展到最初的 20 个工作人员之外，请修改 maxNumWorkers 值。