That's what i really need!Thank you so much!
Yours
Xuyangzhong
在2019-10-21 17:07:21,Till Rohrmann<trohrm...@apache.org>写道：
> Hi Xuyangzhong,
>
> the reason why both split consumers share the same slot is that per default
> slot sharing is activated. You can define separate slot sharing groups via
> `.slotSharingGroup("new_slot_sharing_group")` for the two consumers. This
> will tell Flink to deploy both consumers in different slots.
>
> Cheers,
> Till
>
> On Mon, Oct 21, 2019 at 10:41 AM 钟旭阳 <yeli...@mail.ustc.edu.cn> wrote:
>
> > Hello:
> > I am a graduate student from ustc. I have a little doubt about flink
> > programming recently. I hope to get your reply, thank you.
> > I use the split operator to split a stream into two streams. However, I
> > found that the parallelism of the two streams can only be set separately,
> > so that each of the two streams is itself parallel in multiple slots. But
> > my goal is to get the two streams, one in one slot and the other in another.
> > Specifically, I split the two streams of the split operator, and the
> > degree of parallelism is set to 1, respectively, then they are equivalent
> > to running in the same slot. But my goal is to have them run in two slots
> > separately.
> > Maybe I should use a keyedStream stream and customize KeySelector?
> > I hope to hear from you, thank you again.
> > Best
> > Xuyangzhong
