Re: Re: How to parallel the subsequent flow of the split operator

2019-10-21 Thread 钟旭阳
That's what i really need!Thank you so much! Yours Xuyangzhong 在2019-10-21 17:07:21,Till Rohrmann写道: > 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(

Re: How to parallel the subsequent flow of the split operator

2019-10-21 Thread Till Rohrmann
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 slo

How to parallel the subsequent flow of the split operator

2019-10-21 Thread 钟旭阳
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