Flink disaster recovery test problems

2019-11-04 Thread
hello: I am currently learning flink.I recently had a problem with Flink for disaster recovery testing.I tried to find an answer on the official website and blog but failed.I am trying to find community help. The current situation is:I have two servers, each with one slot.My application has

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

2019-10-21 Thread
lotSharingGroup("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 钟旭阳 wrote: > > > Hello: > > I am a graduate student from ustc.

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