Hi Till, Thank you for your reply. I found such a chain of method calls:
JobMaster#startScheduling -> SchedulerBase#startScheduling -> DefaultScheduler#startSchedulingInternal -> EagerSchedulingStrategy#startScheduling -> EagerSchedulingStrategy#allocateSlotsAndDeploy -> DefaultScheduler#allocateSlotsAndDeploy . (The version of Flink I use is Flink-1.11.1) I'm going to try to see the following code first, but the code annotation seem to be very few.I feel very difficult for my goal and I hope I can get your help later. Sincerely, Penguin At 2021-01-06 17:08:05, "Till Rohrmann" <trohrm...@apache.org> wrote: >Hi Penguin, > >What do you wanna do? If you want to change Flink's scheduling behaviour, >then you can take a look at the implementations of SchedulerNG. > >Cheers, >Till > >On Wed, Jan 6, 2021 at 6:58 AM penguin. <bxwhfh...@126.com> wrote: > >> Hello! Do you know how to modify the task scheduling method of Flink?
