Which runner are you using? On Wed, Apr 29, 2020 at 1:32 PM Eleanore Jin <[email protected]> wrote:
> Hi all, > > I just wonder can Beam allow to set parallelism for each operator > (PTransform) separately? Flink provides such feature. > > The usecase I have is the source is kafka topics, which has less > partitions, while we have heavy PTransform and would like to scale it with > more parallelism. > > Thanks a lot! > Eleanore >
