Re: Parallelism under reactive scaling with slot sharing groups

We were using Flink 1.16. I did some research and it looks like it is fixed in Flink 1.17. On Thu, Jul 27, 2023 at 9:43 PM Weihua Hu wrote: > Hi, > > Which Flink version are you using? I haven't reproduced this issue by > using the master bra

Re: Parallelism under reactive scaling with slot sharing groups

Hi, Which Flink version are you using? I haven't reproduced this issue by using the master branch. Best, Weihua On Tue, Jul 25, 2023 at 2:56 AM Allen Wang wrote: > Hello, > > Our job has operators of source -> sink -> global committer. We have > created two slot sharing groups, one for sourc

Parallelism under reactive scaling with slot sharing groups

Hello, Our job has operators of source -> sink -> global committer. We have created two slot sharing groups, one for source and sink and one for global committer. The global committer has specified max parallelism of 1. No max parallelism set with the source/sink while there is a system level defa